Package | Description |
---|---|
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 | Class and Description |
---|---|
class |
AbstractPiece.InnerVertexSender
Inner class to provide clean use without specifying types
|
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.
|
Modifier and Type | Class and Description |
---|---|
protected class |
DelegatePiece.DelegateWorkerSendFunctions
Delegating WorkerSendPiece
|
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) |
Modifier and Type | Method and Description |
---|---|
VertexSender<I,V,E> |
MigrationPiece.getVertexSender(BlockWorkerSendApi<I,V,E,M> workerApi,
MigrationSuperstepStage executionStage) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.