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

Interface VertexSender<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Type Parameters:

I - Vertex id type

V - Vertex value type

E - Edge value type

All Superinterfaces:

NonKryoWritable

All Known Implementing Classes:

AbstractPiece.InnerVertexSender, DelegatePiece.DelegateWorkerSendFunctions

public interface VertexSender<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends NonKryoWritable

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

• to send messages to vertices
• to send data for aggregation on master

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	vertexSend(Vertex<I,V,E> vertex) Must be defined by user to do computation on a single Vertex.

Method Detail

vertexSend

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

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