org.apache.giraph.block_app.framework

Class TestWorkerMessages.TestWorkerMessagesPiece

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<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,org.apache.hadoop.io.LongWritable,Object>

org.apache.giraph.block_app.framework.TestWorkerMessages.TestWorkerMessagesPiece

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

Enclosing class:

TestWorkerMessages

public static class TestWorkerMessages.TestWorkerMessagesPiece
extends PieceWithWorkerContext<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,org.apache.hadoop.io.LongWritable,Object>

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
TestWorkerMessagesPiece(long... values)

Method Summary

Modifier and Type	Method and Description
void	workerContextReceive(BlockWorkerContextReceiveApi workerContextApi, Object executionStage, Object workerValue, List<org.apache.hadoop.io.LongWritable> workerMessages)
void	workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable> workerContextApi, Object executionStage, Object workerValue)

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

getWorkerValue

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

TestWorkerMessagesPiece

public TestWorkerMessagesPiece(long... values)

Method Detail

workerContextSend

public void workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable> workerContextApi,
                              Object executionStage,
                              Object workerValue)

Overrides:

workerContextSend in class AbstractPiece<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,org.apache.hadoop.io.LongWritable,Object>

workerContextReceive

public void workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
                                 Object executionStage,
                                 Object workerValue,
                                 List<org.apache.hadoop.io.LongWritable> workerMessages)

Overrides:

workerContextReceive in class AbstractPiece<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,org.apache.hadoop.io.LongWritable,Object>