Package | Description |
---|---|
org.apache.giraph.block_app.framework.api |
Interfaces representing full API to the underlying graph processing system.
|
org.apache.giraph.block_app.framework.internal |
Implementation of execution logic, guiding internal execution of
Block Application.
|
org.apache.giraph.block_app.framework.piece |
Single execution object - Piece, and related classes.
|
org.apache.giraph.block_app.framework.piece.delegate |
Pieces that delegate their work to a set of one or multiple other Pieces.
|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
Modifier and Type | Method and Description |
---|---|
BlockWorkerContextReceiveApi |
BlockApiHandle.getWorkerContextReceiveApi() |
Modifier and Type | Method and Description |
---|---|
void |
BlockApiHandle.setWorkerContextReceiveApi(BlockWorkerContextReceiveApi api) |
Modifier and Type | Method and Description |
---|---|
void |
BlockWorkerContextLogic.preSuperstep(BlockWorkerContextReceiveApi receiveApi,
BlockWorkerContextSendApi sendApi,
BlockWorkerPieces workerPieces,
long superstep,
List<org.apache.hadoop.io.Writable> messages) |
void |
PairedPieceAndStage.workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
Object workerValue,
List<org.apache.hadoop.io.Writable> workerMessages) |
Modifier and Type | Method and Description |
---|---|
void |
Piece.workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
S executionStage,
Object workerValue,
List<NoMessage> workerMessages) |
void |
AbstractPiece.workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
S executionStage,
WV workerValue,
List<WM> workerMessages)
Override to have worker context receive computation.
|
Modifier and Type | Method and Description |
---|---|
void |
DelegatePiece.workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
S executionStage,
WV workerValue,
List<WM> workerMessages) |
Modifier and Type | Method and Description |
---|---|
void |
MigrationPiece.workerContextReceive(BlockWorkerContextReceiveApi workerContextApi,
MigrationSuperstepStage executionStage,
MigrationWorkerContext workerValue,
List<org.apache.hadoop.io.Writable> workerMessages) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.