Package org.apache.giraph.block_app.framework.piece.delegate

Pieces that delegate their work to a set of one or multiple other Pieces.

See: Description

Class Summary

Class	Description
DelegatePiece<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable,WV,WM extends org.apache.hadoop.io.Writable,S>	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.
FilteringPiece<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable,WV,WM extends org.apache.hadoop.io.Writable,S>	Piece which uses a provided suppliers to decide whether or not to run receive/send piece part on a certain vertex.

Package org.apache.giraph.block_app.framework.piece.delegate Description

Pieces that delegate their work to a set of one or multiple other Pieces.