public class Seeder extends org.apache.giraph.graph.AbstractComputation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
Constructor and Description |
---|
Seeder() |
Modifier and Type | Method and Description |
---|---|
void |
compute(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex,
java.lang.Iterable<LayoutMessage> msgs) |
void |
initialize(org.apache.giraph.graph.GraphState graphState,
org.apache.giraph.comm.WorkerClientRequestProcessor<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> workerClientRequestProcessor,
org.apache.giraph.graph.GraphTaskManager<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> graphTaskManager,
org.apache.giraph.worker.WorkerGlobalCommUsage workerGlobalCommUsage,
org.apache.giraph.worker.WorkerContext workerContext) |
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
aggregate, getAggregatedValue, getBroadcast, reduce, setWorkerGlobalCommUsage
getConf, setConf
public void compute(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex, java.lang.Iterable<LayoutMessage> msgs) throws java.io.IOException
compute
in interface org.apache.giraph.graph.Computation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
compute
in class org.apache.giraph.graph.AbstractComputation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
java.io.IOException
public void initialize(org.apache.giraph.graph.GraphState graphState, org.apache.giraph.comm.WorkerClientRequestProcessor<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> workerClientRequestProcessor, org.apache.giraph.graph.GraphTaskManager<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> graphTaskManager, org.apache.giraph.worker.WorkerGlobalCommUsage workerGlobalCommUsage, org.apache.giraph.worker.WorkerContext workerContext)
initialize
in interface org.apache.giraph.graph.Computation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
initialize
in class org.apache.giraph.graph.AbstractComputation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>