org.apache.giraph.block_app.framework

Class BlockApiHandleTest.TestPiece

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

org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

Enclosing class:

BlockApiHandleTest

public static class BlockApiHandleTest.TestPiece
extends DefaultParentPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable,Object,org.apache.hadoop.io.DoubleWritable,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
TestPiece(BlockApiHandleTest.DummyObjectWithApiHandle object)

Method Summary

Modifier and Type	Method and Description
protected Class<org.apache.hadoop.io.NullWritable>	getMessageClass()
VertexReceiver<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable>	getVertexReceiver(BlockWorkerReceiveApi<org.apache.hadoop.io.WritableComparable> workerApi, Object executionStage)
VertexSender<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable>	getVertexSender(BlockWorkerSendApi<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable> workerApi, Object executionStage)
void	masterCompute(BlockMasterApi masterApi, Object executionStage)
void	workerContextReceive(BlockWorkerContextReceiveApi workerContextApi, Object executionStage, Object workerValue, List<org.apache.hadoop.io.DoubleWritable> workerMessages) Override to have worker context receive computation.
void	workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.DoubleWritable> workerContextApi, Object executionStage, org.apache.hadoop.io.Writable workerValue)

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

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

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

equals, forAllPossiblePieces, getPieceCount, hashCode, iterator, nextExecutionStage, registerAggregators, toString, 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

TestPiece

public TestPiece(BlockApiHandleTest.DummyObjectWithApiHandle object)

Method Detail

getVertexSender

public VertexSender<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable> getVertexSender(BlockWorkerSendApi<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable> workerApi,
                                                                                                                                             Object executionStage)

Overrides:

getVertexSender in class DefaultParentPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable,Object,org.apache.hadoop.io.DoubleWritable,Object>

getVertexReceiver

public VertexReceiver<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable> getVertexReceiver(BlockWorkerReceiveApi<org.apache.hadoop.io.WritableComparable> workerApi,
                                                                                                                                                                                   Object executionStage)

Overrides:

getVertexReceiver in class AbstractPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable,Object,org.apache.hadoop.io.DoubleWritable,Object>

workerContextSend

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

workerContextReceive

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

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

masterCompute

public void masterCompute(BlockMasterApi masterApi,
                          Object executionStage)

Overrides:

masterCompute in class AbstractPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable,Object,org.apache.hadoop.io.DoubleWritable,Object>

getMessageClass

protected Class<org.apache.hadoop.io.NullWritable> getMessageClass()

Overrides:

getMessageClass in class DefaultParentPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable,Object,org.apache.hadoop.io.DoubleWritable,Object>