Package | Description |
---|---|
org.apache.giraph.block_app.framework.internal |
Implementation of execution logic, guiding internal execution of
Block Application.
|
Modifier and Type | Method and Description |
---|---|
BlockWorkerPieces<S> |
BlockMasterLogic.computeNext(long superstep)
Executes operations on master (master compute and registering reducers),
and calculates next pieces to be exectued on workers.
|
static <S> BlockWorkerPieces<S> |
BlockWorkerPieces.getNextWorkerPieces(WorkerGlobalCommUsage worker) |
Modifier and Type | Method and Description |
---|---|
void |
BlockWorkerContextLogic.preSuperstep(BlockWorkerContextReceiveApi receiveApi,
BlockWorkerContextSendApi sendApi,
BlockWorkerPieces workerPieces,
long superstep,
List<org.apache.hadoop.io.Writable> messages) |
static <S> void |
BlockWorkerPieces.setNextWorkerPieces(MasterCompute master,
BlockWorkerPieces<S> nextWorkerPieces)
Sets which WorkerComputation is going to be executed in the next superstep.
|
static void |
BlockCounters.setWorkerTimeCounter(BlockWorkerPieces<?> workerPieces,
long superstep,
long millis,
StatusReporter reporter,
BlockMasterLogic.TimeStatsPerEvent timeStats) |
Constructor and Description |
---|
BlockWorkerLogic(BlockWorkerPieces pieces) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.