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

Class DelegatePiece.DelegateWorkerSendFunctions

java.lang.Object

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

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

All Implemented Interfaces:

VertexPostprocessor, VertexSender<I,V,E>, 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.DelegateWorkerSendFunctions
extends AbstractPiece.InnerVertexSender

Delegating WorkerSendPiece

Constructor Summary

Constructors

Constructor and Description
DelegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions)

Method Summary

Modifier and Type	Method and Description
void	postprocess() Override to finish computation.
void	vertexSend(Vertex<I,V,E> vertex) 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

DelegateWorkerSendFunctions

public DelegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions)

Method Detail

vertexSend

public void vertexSend(Vertex<I,V,E> vertex)

Description copied from interface: VertexSender

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

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.InnerVertexSender