Package org.apache.giraph.block_app.framework.piece.global_comm.internal

Reducer and Broadcast Handles internal implementation for automatic handling of global communication within Pieces, hiding a lot of it's complexities.

See: Description

Interface Summary

Interface	Description
VertexSenderObserver	Observer able to hook into vertex sender pre/post processing

Class Summary

Class	Description
CreateReducersApiWrapper	Wrapping masterApi and reducers handler into API for creating reducer handles.
ReducersForPieceHandler	All logic for transforming Giraph's reducer API to reducer handles.
ReducersForPieceHandler.BroadcastHandleImpl<T>	Implementation of BroadcastHandle
ReducersForPieceHandler.WrappedReducedValue<R extends org.apache.hadoop.io.Writable>	Wrapper that makes reduced values self-serializable, and allows them to be broadcasted.

Package org.apache.giraph.block_app.framework.piece.global_comm.internal Description

Reducer and Broadcast Handles internal implementation for automatic handling of global communication within Pieces, hiding a lot of it's complexities.