org.apache.giraph.block_app.framework.internal

Class BlockWorkerPieces<S>

java.lang.Object

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

Type Parameters:

S - Execution stage type

public class BlockWorkerPieces<S>
extends Object

Pair of pieces to be executed on workers in a superstep

Constructor Summary

Constructors

Constructor and Description
BlockWorkerPieces(PairedPieceAndStage<S> receiver, PairedPieceAndStage<S> sender, BlockApiHandle blockApiHandle)

Method Summary

Modifier and Type	Method and Description
BlockApiHandle	getBlockApiHandle()
static <S> BlockWorkerPieces<S>	getNextWorkerPieces(WorkerGlobalCommUsage worker)
MessageClasses	getOutgoingMessageClasses(ImmutableClassesGiraphConfiguration conf)
PairedPieceAndStage<S>	getReceiver()
PairedPieceAndStage<S>	getSender()
static <S> void	setNextWorkerPieces(MasterCompute master, BlockWorkerPieces<S> nextWorkerPieces) Sets which WorkerComputation is going to be executed in the next superstep.
String	toString()
String	toStringShort()

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockWorkerPieces

public BlockWorkerPieces(PairedPieceAndStage<S> receiver,
                         PairedPieceAndStage<S> sender,
                         BlockApiHandle blockApiHandle)

Method Detail

getReceiver

public PairedPieceAndStage<S> getReceiver()

getSender

public PairedPieceAndStage<S> getSender()

getBlockApiHandle

public BlockApiHandle getBlockApiHandle()

getOutgoingMessageClasses

public MessageClasses getOutgoingMessageClasses(ImmutableClassesGiraphConfiguration conf)

toString

public String toString()

Overrides:

toString in class Object

toStringShort

public String toStringShort()

setNextWorkerPieces

public static <S> void setNextWorkerPieces(MasterCompute master,
                                           BlockWorkerPieces<S> nextWorkerPieces)

Sets which WorkerComputation is going to be executed in the next superstep.

getNextWorkerPieces

public static <S> BlockWorkerPieces<S> getNextWorkerPieces(WorkerGlobalCommUsage worker)