Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece.delegate |
Pieces that delegate their work to a set of one or multiple other Pieces.
|
Class and Description |
---|
DelegatePiece
Delegate Piece which allows combining multiple pieces in same iteration:
new DelegatePiece(new LogicPiece(), new StatsPiece())
You should be careful when doing so, since those pieces must not interact,
and only one can send messages.
|
DelegatePiece.DelegateWorkerReceiveFunctions
Delegating WorkerReceivePiece
|
DelegatePiece.DelegateWorkerSendFunctions
Delegating WorkerSendPiece
|
FilteringPiece
Piece which uses a provided suppliers to decide whether or not to run
receive/send piece part on a certain vertex.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.