org.apache.giraph.block_app.library.iteration

Class IterationCounterPiece

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<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,IterationStage>

org.apache.giraph.block_app.library.iteration.IterationCounterPiece

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

public class IterationCounterPiece
extends Piece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,IterationStage>

Piece that increments execution stage iteration.

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

Method Summary

Modifier and Type	Method and Description
IterationStage	nextExecutionStage(IterationStage executionStage) Override to provide different next execution stage for Pieces that come after it.

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

workerContextReceive, workerContextSend

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

IterationCounterPiece

public IterationCounterPiece()

Method Detail

nextExecutionStage

public IterationStage nextExecutionStage(IterationStage executionStage)

Description copied from class: AbstractPiece

Override to provide different next execution stage for Pieces that come after it. Execution stage should be immutable, and this function should be returning a new object, if it needs to return different value. It affects pieces that come after this piece, and isn't applied to execution stage this piece sees.

Overrides:

nextExecutionStage in class AbstractPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,Object,NoMessage,IterationStage>