| 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.internal |
Internal implementation of Pieces needed for Pieces utility class.
|
| org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
| Modifier and Type | Method and Description |
|---|---|
BlockWorkerReceiveApi |
BlockApiHandle.getWorkerReceiveApi() |
| Modifier and Type | Method and Description |
|---|---|
void |
BlockApiHandle.setWorkerReceiveApi(BlockWorkerReceiveApi api) |
| Modifier and Type | Method and Description |
|---|---|
VertexReceiver |
PairedPieceAndStage.getVertexReceiver(BlockWorkerReceiveApi receiveApi) |
void |
BlockWorkerLogic.preSuperstep(BlockWorkerReceiveApi receiveApi,
BlockWorkerSendApi sendApi) |
| Modifier and Type | Method and Description |
|---|---|
VertexReceiver<I,V,E,M> |
AbstractPiece.getVertexReceiver(BlockWorkerReceiveApi<I> workerApi,
S executionStage)
Override to do vertex receive processing.
|
| Modifier and Type | Method and Description |
|---|---|
protected DelegatePiece.DelegateWorkerReceiveFunctions |
DelegatePiece.delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions,
BlockWorkerReceiveApi<I> workerApi,
S executionStage) |
protected DelegatePiece.DelegateWorkerReceiveFunctions |
FilteringPiece.delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions,
BlockWorkerReceiveApi<I> workerApi,
S executionStage) |
AbstractPiece.InnerVertexReceiver |
DelegatePiece.getVertexReceiver(BlockWorkerReceiveApi<I> workerApi,
S executionStage) |
| Modifier and Type | Method and Description |
|---|---|
VertexReceiver<I,V,E,M> |
SendMessageWithCombinerPiece.getVertexReceiver(BlockWorkerReceiveApi<I> workerApi,
Object executionStage) |
VertexReceiver<I,V,E,M> |
SendMessagePiece.getVertexReceiver(BlockWorkerReceiveApi<I> workerApi,
Object executionStage) |
| Modifier and Type | Method and Description |
|---|---|
VertexReceiver<I,V,E,M> |
MigrationPiece.getVertexReceiver(BlockWorkerReceiveApi<I> workerApi,
MigrationSuperstepStage executionStage) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.