public final class BlockComputation extends AbstractComputation
Constructor and Description |
---|
BlockComputation() |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex vertex,
Iterable messages) |
void |
postSuperstep() |
void |
preSuperstep() |
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, getWorkerCount, getWorkerForVertex, initialize, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf
setConf
getBroadcast
reduce, reduceMerge
aggregate
getAggregatedValue
public void preSuperstep()
preSuperstep
in interface Computation
preSuperstep
in class AbstractComputation
public void compute(Vertex vertex, Iterable messages) throws IOException
compute
in interface Computation
compute
in class AbstractComputation
IOException
public void postSuperstep()
postSuperstep
in interface Computation
postSuperstep
in class AbstractComputation
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.