Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
AbstractPiece.InnerVertexSender |
PairedPieceAndStage.getVertexSender(BlockWorkerSendApi sendApi) |
Modifier and Type | Method and Description |
---|---|
AbstractPiece.InnerVertexSender |
DefaultParentPiece.getWrappedVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi,
S executionStage) |
abstract AbstractPiece.InnerVertexSender |
AbstractPiece.getWrappedVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi,
S executionStage)
Add automatic handling of reducers to getVertexSender.
|
Modifier and Type | Class and Description |
---|---|
protected class |
DelegatePiece.DelegateWorkerSendFunctions
Delegating WorkerSendPiece
|
Modifier and Type | Method and Description |
---|---|
AbstractPiece.InnerVertexSender |
DelegatePiece.getWrappedVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi,
S executionStage) |
Modifier and Type | Method and Description |
---|---|
protected DelegatePiece.DelegateWorkerSendFunctions |
DelegatePiece.delegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions,
BlockWorkerSendApi<I,V,E,M> workerApi,
S executionStage) |
protected DelegatePiece.DelegateWorkerSendFunctions |
FilteringPiece.delegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions,
BlockWorkerSendApi<I,V,E,M> workerApi,
S executionStage) |
Constructor and Description |
---|
DelegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.