org.apache.giraph.block_app.framework.piece.interfaces

Interface VertexReceiver<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>

Type Parameters:

I - Vertex id type

V - Vertex value type

E - Edge value type

M - Message type

All Superinterfaces:

NonKryoWritable

All Known Implementing Classes:

AbstractPiece.InnerVertexReceiver, DelegatePiece.DelegateWorkerReceiveFunctions

public interface VertexReceiver<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>
extends NonKryoWritable

Interface representing actions that happen on worker, for each vertex, during receive phase:

• to receive messages from vertices
• to receive data from master through aggregators

Marked to not allow seriazliation, as it should be created on the worker, so should never be serialiized, disallow only for catching problems early.

Method Summary

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

Method Detail

vertexReceive

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

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.