public class SccComputation extends BasicComputation<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.LongWritable>
Constructor and Description |
---|
SccComputation() |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable> vertex,
Iterable<org.apache.hadoop.io.LongWritable> messages) |
void |
preSuperstep() |
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, getWorkerCount, getWorkerForVertex, initialize, postSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf
setConf
getBroadcast
reduce, reduceMerge
aggregate
getAggregatedValue
public void preSuperstep()
preSuperstep
in interface Computation<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
preSuperstep
in class AbstractComputation<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
public void compute(Vertex<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable> vertex, Iterable<org.apache.hadoop.io.LongWritable> messages) throws IOException
compute
in interface Computation<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
compute
in class AbstractComputation<org.apache.hadoop.io.LongWritable,SccVertexValue,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.