org.apache.giraph.block_app.framework.internal

Class BlockMasterLogic<S>

java.lang.Object

org.apache.giraph.block_app.framework.internal.BlockMasterLogic<S>

Type Parameters:

S - Execution stage type

public class BlockMasterLogic<S>
extends Object

Block execution logic on master, iterating over Pieces of the application Block, executing master logic, and providing what needs to be executed on the workers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockMasterLogic.TimeStatsPerEvent Class tracking invocation count and elapsed time for a set of events, each event being having a String name.

Constructor Summary

Constructors

Constructor and Description
BlockMasterLogic()

Method Summary

Modifier and Type	Method and Description
BlockWorkerPieces<S>	computeNext(long superstep) Executes operations on master (master compute and registering reducers), and calculates next pieces to be exectued on workers.
void	initialize(Block executionBlock, S executionStage, BlockMasterApi masterApi) Initialize Master Logic to execute given block, starting with given executionStage.
void	initialize(GiraphConfiguration conf, BlockMasterApi masterApi) Initialize master logic to execute BlockFactory defined in the configuration.
void	initializeAfterRead(BlockMasterApi masterApi) Initialize object after deserializing it.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlockMasterLogic

public BlockMasterLogic()

Method Detail

initialize

public void initialize(GiraphConfiguration conf,
                       BlockMasterApi masterApi)

Initialize master logic to execute BlockFactory defined in the configuration.

initialize

public void initialize(Block executionBlock,
                       S executionStage,
                       BlockMasterApi masterApi)

Initialize Master Logic to execute given block, starting with given executionStage.

initializeAfterRead

public void initializeAfterRead(BlockMasterApi masterApi)

Initialize object after deserializing it. BlockMasterApi is not serializable, so it is transient, and set via this method afterwards.

computeNext

public BlockWorkerPieces<S> computeNext(long superstep)

Executes operations on master (master compute and registering reducers), and calculates next pieces to be exectued on workers.

Parameters:

superstep - Current superstep

Returns:

Next BlockWorkerPieces to be executed on workers, or null if computation should be halted.