public static class Spinner.ComputeMigration extends org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.NullWritable,PartitionMessage>
Constructor and Description |
---|
Spinner.ComputeMigration() |
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.NullWritable> messages) |
void |
preSuperstep() |
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, initialize, postSuperstep, 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.NullWritable> messages) throws java.io.IOException
compute
in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.NullWritable,PartitionMessage>
compute
in class org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.NullWritable,PartitionMessage>
java.io.IOException
public void preSuperstep()
preSuperstep
in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.NullWritable,PartitionMessage>
preSuperstep
in class org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,org.apache.hadoop.io.NullWritable,PartitionMessage>