org.apache.giraph.block_app.framework.piece.delegate

Class DelegatePiece.DelegateWorkerReceiveFunctions

java.lang.Object

org.apache.giraph.block_app.framework.piece.AbstractPiece.InnerVertexReceiver

org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece.DelegateWorkerReceiveFunctions

All Implemented Interfaces:

VertexPostprocessor, VertexReceiver<I,V,E,M>, NonKryoWritable

Enclosing class:

DelegatePiece<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable,WV,WM extends org.apache.hadoop.io.Writable,S>

protected class DelegatePiece.DelegateWorkerReceiveFunctions
extends AbstractPiece.InnerVertexReceiver

Delegating WorkerReceivePiece

Constructor Summary

Constructors

Constructor and Description
DelegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions)

Method Summary

Modifier and Type	Method and Description
void	postprocess() Override to finish computation.
void	vertexReceive(Vertex<I,V,E> vertex, Iterable<M> messages) Must be defined by user to do computation on a single Vertex.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegateWorkerReceiveFunctions

public DelegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions)

Method Detail

vertexReceive

public void vertexReceive(Vertex<I,V,E> vertex,
                          Iterable<M> messages)

Description copied from interface: VertexReceiver

Must be defined by user to do computation on a single Vertex.

Parameters:

vertex - Vertex

messages - Messages that were sent to this vertex in the previous superstep. Each message is only guaranteed to have a life expectancy as long as next() is not called.

postprocess

public void postprocess()

Description copied from interface: VertexPostprocessor

Override to finish computation. This method is executed exactly once after computation for all vertices in the partition is complete.

Specified by:

postprocess in interface VertexPostprocessor

Overrides:

postprocess in class AbstractPiece.InnerVertexReceiver