org.apache.giraph.block_app.framework.piece

Class Piece<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,S>

java.lang.Object

org.apache.giraph.block_app.framework.piece.AbstractPiece<I,V,E,M,WV,WM,S>

org.apache.giraph.block_app.framework.piece.DefaultParentPiece<I,V,E,M,Object,NoMessage,S>

org.apache.giraph.block_app.framework.piece.Piece<I,V,E,M,S>

Type Parameters:

I - Vertex id type

V - Vertex value type

E - Edge value type

M - Message type

S - Execution stage type

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

Direct Known Subclasses:

IterationCounterPiece, SendMessagePiece, SendMessageWithCombinerPiece

public class Piece<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,S>
extends DefaultParentPiece<I,V,E,M,Object,NoMessage,S>

Piece that should be extended in common usecases, when we want to be: - sending and then receiving messages from vertices - sending data to be aggregated from workers to master - sending values from master, via aggregators, to workers (basically - we don't want to use WorkerContext)

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.block_app.framework.piece.AbstractPiece

AbstractPiece.InnerVertexReceiver, AbstractPiece.InnerVertexSender

Field Summary

Fields inherited from class org.apache.giraph.block_app.framework.piece.DefaultParentPiece

MESSAGE_ENCODE_AND_STORE_TYPE_MIN_FORCE

Constructor Summary

Constructors

Constructor and Description
Piece()

Method Summary

Modifier and Type	Method and Description
void	workerContextReceive(BlockWorkerContextReceiveApi workerContextApi, S executionStage, Object workerValue, List<NoMessage> workerMessages) Override to have worker context receive computation.
void	workerContextSend(BlockWorkerContextSendApi<I,NoMessage> workerContextApi, S executionStage, Object workerValue) Override to have worker context send computation.

Methods inherited from class org.apache.giraph.block_app.framework.piece.DefaultParentPiece

allowOneMessageToManyIdsEncoding, getMessageClass, getMessageClasses, getMessageCombiner, getMessageFactory, getVertexSender, getWrappedVertexSender, receiveIgnoreExistingVertices, reduceDouble, reduceFloat, reduceInt, reduceLong, registerReducers, wrappedRegisterReducers

Methods inherited from class org.apache.giraph.block_app.framework.piece.AbstractPiece

equals, forAllPossiblePieces, getPieceCount, getVertexReceiver, hashCode, iterator, masterCompute, nextExecutionStage, registerAggregators, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

Piece

public Piece()

Method Detail

workerContextSend

public final void workerContextSend(BlockWorkerContextSendApi<I,NoMessage> workerContextApi,
                                    S executionStage,
                                    Object workerValue)

Description copied from class: AbstractPiece

Override to have worker context send computation. Called once per worker, after all vertices have been processed with getVertexSender.

Overrides:

workerContextSend in class AbstractPiece<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,Object,NoMessage,S>

workerContextReceive

public final void workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
                                       S executionStage,
                                       Object workerValue,
                                       List<NoMessage> workerMessages)

Description copied from class: AbstractPiece

Override to have worker context receive computation. Called once per worker, before all vertices are going to be processed with getVertexReceiver.

Overrides:

workerContextReceive in class AbstractPiece<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,Object,NoMessage,S>