public class Propagator extends org.apache.giraph.graph.AbstractComputation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
Modifier and Type | Field and Description |
---|---|
protected Force |
force |
protected java.lang.Float |
k |
protected float |
minimumForceThreshold |
protected float |
walshawConstant |
Constructor and Description |
---|
Propagator() |
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> messages) |
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
protected Force force
protected java.lang.Float k
protected float minimumForceThreshold
protected float walshawConstant
public void compute(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex, java.lang.Iterable<LayoutMessage> messages) 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>