S
- Execution stage typepublic class PairedPieceAndStage<S> extends Object
Constructor and Description |
---|
PairedPieceAndStage(AbstractPiece piece,
S executionStage) |
Modifier and Type | Method and Description |
---|---|
S |
getExecutionStage() |
AbstractPiece |
getPiece() |
VertexReceiver |
getVertexReceiver(BlockWorkerReceiveApi receiveApi) |
AbstractPiece.InnerVertexSender |
getVertexSender(BlockWorkerSendApi sendApi) |
void |
masterCompute(BlockMasterApi masterApi) |
S |
nextExecutionStage() |
void |
registerReducers(BlockMasterApi masterApi) |
String |
toString() |
void |
workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
Object workerValue,
List<org.apache.hadoop.io.Writable> workerMessages) |
void |
workerContextSend(BlockWorkerContextSendApi workerContextApi,
Object workerValue) |
public PairedPieceAndStage(AbstractPiece piece, S executionStage)
public S nextExecutionStage()
public S getExecutionStage()
public void registerReducers(BlockMasterApi masterApi)
public AbstractPiece.InnerVertexSender getVertexSender(BlockWorkerSendApi sendApi)
public void masterCompute(BlockMasterApi masterApi)
public VertexReceiver getVertexReceiver(BlockWorkerReceiveApi receiveApi)
public void workerContextSend(BlockWorkerContextSendApi workerContextApi, Object workerValue)
public void workerContextReceive(BlockWorkerContextReceiveApi workerContextApi, Object workerValue, List<org.apache.hadoop.io.Writable> workerMessages)
public AbstractPiece getPiece()
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.