org.apache.giraph.block_app.framework.piece

Class PieceWithWorkerContext<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>

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,WV,WM,S>

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

Type Parameters:

I - Vertex id type

V - Vertex value type

E - Edge value type

M - Message type

WV - Worker value type

WM - Worker message type

S - Execution stage type

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

Direct Known Subclasses:

MigrationPiece, WorkerGCPiece

public class PieceWithWorkerContext<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>
extends DefaultParentPiece<I,V,E,M,WV,WM,S>

Piece that should be extended when WorkerContext is used.

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
PieceWithWorkerContext()

Method Summary

Modifier and Type	Method and Description
WV	getWorkerValue(BlockWorkerApi<I> workerApi) Get global worker value.

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, workerContextReceive, workerContextSend

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

PieceWithWorkerContext

public PieceWithWorkerContext()

Method Detail

getWorkerValue

public WV getWorkerValue(BlockWorkerApi<I> workerApi)

Get global worker value. Value returned can be accessed from may threads, and so all accesses to it should be done in a thread-safe manner! This is the only place in Blocks Framework where you need to take care of concurrency.