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.library.gc |
GC utility pieces.
|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
Modifier and Type | Method and Description |
---|---|
BlockWorkerContextSendApi |
BlockApiHandle.getWorkerContextSendApi() |
Modifier and Type | Method and Description |
---|---|
void |
BlockApiHandle.setWorkerContextSendApi(BlockWorkerContextSendApi 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.workerContextSend(BlockWorkerContextSendApi workerContextApi,
Object workerValue) |
Modifier and Type | Method and Description |
---|---|
void |
Piece.workerContextSend(BlockWorkerContextSendApi<I,NoMessage> workerContextApi,
S executionStage,
Object workerValue) |
void |
AbstractPiece.workerContextSend(BlockWorkerContextSendApi<I,WM> workerContextApi,
S executionStage,
WV workerValue)
Override to have worker context send computation.
|
Modifier and Type | Method and Description |
---|---|
void |
DelegatePiece.workerContextSend(BlockWorkerContextSendApi<I,WM> workerContextApi,
S executionStage,
WV workerValue) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerGCPiece.workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.WritableComparable,NoMessage> workerContextApi,
Object executionStage,
Object workerValue) |
Modifier and Type | Method and Description |
---|---|
void |
MigrationPiece.workerContextSend(BlockWorkerContextSendApi<I,org.apache.hadoop.io.Writable> workerContextApi,
MigrationSuperstepStage executionStage,
MigrationWorkerContext workerValue) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.