public static class Spinner.ConverterPropagate extends org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.LongWritable,DegMessage>
Constructor and Description |
---|
Spinner.ConverterPropagate() |
Modifier and Type | Method and Description |
---|---|
void |
compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue> vertex,
java.lang.Iterable<org.apache.hadoop.io.LongWritable> messages) |
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, initialize, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
aggregate, getAggregatedValue, getBroadcast, reduce, setWorkerGlobalCommUsage
getConf, setConf
public void compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue> vertex, java.lang.Iterable<org.apache.hadoop.io.LongWritable> messages) throws java.io.IOException
compute
in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.LongWritable,DegMessage>
compute
in class org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.LongWritable,DegMessage>
java.io.IOException