Package com.alibaba.graphscope.example.giraph.circle

Class Circle

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<OID_T,VDATA_T,EDATA_T>

org.apache.giraph.graph.AbstractComputation<I,V,E,M,M>

org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable,VertexAttrWritable>

com.alibaba.graphscope.example.giraph.circle.Circle

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable>, org.apache.giraph.conf.TypesHolder<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable,VertexAttrWritable,VertexAttrWritable>, org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable,VertexAttrWritable,VertexAttrWritable>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerIndexUsage<org.apache.hadoop.io.LongWritable>, org.apache.giraph.worker.WorkerReduceUsage

public class Circle
extends org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable,VertexAttrWritable>

Constructor Summary

Constructors

Constructor	Description
Circle()

Method Summary

Modifier and Type	Method	Description
void	compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable> vertex, Iterable<VertexAttrWritable> messages)
void	preSuperstep()	Prepare for computation.

Methods inherited from class org.apache.giraph.graph.AbstractComputation

addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, getWorkerCount, getWorkerForVertex, incStep, initialize, postSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges, setFragment, setGiraphMessageManager, setWorkerContext

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setAggregatorManager

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage

getAggregatedValue

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

setConf

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

getConf

Methods inherited from interface org.apache.giraph.worker.WorkerAggregatorUsage

aggregate

Methods inherited from interface org.apache.giraph.worker.WorkerBroadcastUsage

getBroadcast

Methods inherited from interface org.apache.giraph.worker.WorkerReduceUsage

reduce, reduceMerge

Constructor Detail

Circle

public Circle()

Method Detail

preSuperstep

public void preSuperstep()

Description copied from class: AbstractComputation

Prepare for computation. This method is executed exactly once prior to Computation.compute(Vertex, Iterable) being called for any of the vertices in the partition.

Specified by:

preSuperstep in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable,VertexAttrWritable,VertexAttrWritable>

Overrides:

preSuperstep in class AbstractComputation<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable,VertexAttrWritable,VertexAttrWritable>

compute

public void compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,VertexAttrWritable,org.apache.hadoop.io.LongWritable> vertex,
                    Iterable<VertexAttrWritable> messages)
             throws IOException

Throws:

IOException