Uses of Interface
org.apache.giraph.block_app.framework.api.BlockWorkerSendApi

Packages that use BlockWorkerSendApi

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.

Uses of BlockWorkerSendApi in org.apache.giraph.block_app.framework.api

Methods in org.apache.giraph.block_app.framework.api that return BlockWorkerSendApi

Modifier and Type	Method and Description
BlockWorkerSendApi	BlockApiHandle.getWorkerSendApi()

Methods in org.apache.giraph.block_app.framework.api with parameters of type BlockWorkerSendApi

Modifier and Type	Method and Description
void	BlockApiHandle.setWorkerSendApi(BlockWorkerSendApi api)

Uses of BlockWorkerSendApi in org.apache.giraph.block_app.framework.internal

Methods in org.apache.giraph.block_app.framework.internal with parameters of type BlockWorkerSendApi

Modifier and Type	Method and Description
AbstractPiece.InnerVertexSender	PairedPieceAndStage.getVertexSender(BlockWorkerSendApi sendApi)
void	BlockWorkerLogic.preSuperstep(BlockWorkerReceiveApi receiveApi, BlockWorkerSendApi sendApi)

Uses of BlockWorkerSendApi in org.apache.giraph.block_app.framework.piece

Methods in org.apache.giraph.block_app.framework.piece with parameters of type BlockWorkerSendApi

Modifier and Type	Method and Description
VertexSender<I,V,E>	DefaultParentPiece.getVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi, S executionStage) Override to do vertex send processing.
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.

Uses of BlockWorkerSendApi in org.apache.giraph.block_app.framework.piece.delegate

Methods in org.apache.giraph.block_app.framework.piece.delegate with parameters of type BlockWorkerSendApi

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)
AbstractPiece.InnerVertexSender	DelegatePiece.getWrappedVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi, S executionStage)

Uses of BlockWorkerSendApi in org.apache.giraph.block_app.library.internal

Methods in org.apache.giraph.block_app.library.internal with parameters of type BlockWorkerSendApi

Modifier and Type	Method and Description
VertexSender<I,V,E>	SendMessageWithCombinerPiece.getVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi, Object executionStage)
VertexSender<I,V,E>	SendMessagePiece.getVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi, Object executionStage)

Uses of BlockWorkerSendApi in org.apache.giraph.block_app.migration

Methods in org.apache.giraph.block_app.migration with parameters of type BlockWorkerSendApi

Modifier and Type	Method and Description
VertexSender<I,V,E>	MigrationPiece.getVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi, MigrationSuperstepStage executionStage)