Uses of Interface
org.apache.giraph.block_app.framework.piece.global_comm.ReducerHandle

Packages that use ReducerHandle

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.piece	Single execution object - Piece, and related classes.
org.apache.giraph.block_app.framework.piece.global_comm	Interfaces for Reducer and Broadcast Handles for automatic handling of global communication within Pieces, hiding a lot of it's complexities.
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.
org.apache.giraph.block_app.reducers.array	Reducers for collecting arrays of objects.
org.apache.giraph.block_app.reducers.collect	Reducers for distributed collection of objects.

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

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

Modifier and Type	Method and Description
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApi.createGlobalReducer(ReduceOperation<S,R> reduceOp) Create global reducer, returning a handle to it.
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApi.createGlobalReducer(ReduceOperation<S,R> reduceOp, R globalInitialValue) Create global reducer, returning a handle to it.
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApi.createLocalReducer(ReduceOperation<S,R> reduceOp) Create local reducer, returning a handle to it.
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApi.createLocalReducer(ReduceOperation<S,R> reduceOp, R globalInitialValue) Create local reducer, returning a handle to it.
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApi.CreateReducerFunctionApi.createReducer(ReduceOperation<S,R> reduceOp)

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

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

Modifier and Type	Method and Description
protected void	DefaultParentPiece.reduceDouble(ReducerHandle<org.apache.hadoop.io.DoubleWritable,?> reduceHandle, double value)
protected void	DefaultParentPiece.reduceFloat(ReducerHandle<org.apache.hadoop.io.FloatWritable,?> reduceHandle, float value)
protected void	DefaultParentPiece.reduceInt(ReducerHandle<org.apache.hadoop.io.IntWritable,?> reduceHandle, int value)
protected void	DefaultParentPiece.reduceLong(ReducerHandle<org.apache.hadoop.io.LongWritable,?> reduceHandle, long value)

Uses of ReducerHandle in org.apache.giraph.block_app.framework.piece.global_comm

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

Modifier and Type	Method and Description
void	ReduceUtilsObject.reduceDouble(ReducerHandle<org.apache.hadoop.io.DoubleWritable,?> reduceHandle, double value)
void	ReduceUtilsObject.reduceFloat(ReducerHandle<org.apache.hadoop.io.FloatWritable,?> reduceHandle, float value)
void	ReduceUtilsObject.reduceInt(ReducerHandle<org.apache.hadoop.io.IntWritable,?> reduceHandle, int value)
void	ReduceUtilsObject.reduceLong(ReducerHandle<org.apache.hadoop.io.LongWritable,?> reduceHandle, long value)
void	ReducerAndBroadcastWrapperHandle.registeredReducer(ReducerHandle<S,R> reducerHandle) Set reducer handle to just registered handle

Uses of ReducerHandle in org.apache.giraph.block_app.framework.piece.global_comm.internal

Classes in org.apache.giraph.block_app.framework.piece.global_comm.internal that implement ReducerHandle

Modifier and Type	Class and Description
class	ReducersForPieceHandler.GlobalReduceHandle<S,R extends org.apache.hadoop.io.Writable> Global Reduce Handle is implementation of ReducerHandle, that will keep only one value for each worker, and each call to reduce will have to obtain a global lock, and incur synchronization costs.
class	ReducersForPieceHandler.LocalReduceHandle<S,R extends org.apache.hadoop.io.Writable> Local Reduce Handle is implementation of ReducerHandle, that will make a partially reduced value on each worker thread, which are at the end reduced all together.
class	ReducersForPieceHandler.ReduceHandleImpl<S,R extends org.apache.hadoop.io.Writable> Parent implementation of ReducerHandle

Methods in org.apache.giraph.block_app.framework.piece.global_comm.internal that return ReducerHandle

Modifier and Type	Method and Description
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	ReducersForPieceHandler.createGlobalReducer(MasterGlobalCommUsage master, ReduceOperation<S,R> reduceOp, R globalInitialValue)
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApiWrapper.createGlobalReducer(ReduceOperation<S,R> reduceOp)
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApiWrapper.createGlobalReducer(ReduceOperation<S,R> reduceOp, R globalInitialValue)
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	ReducersForPieceHandler.createLocalReducer(MasterGlobalCommUsage master, ReduceOperation<S,R> reduceOp, R globalInitialValue)
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApiWrapper.createLocalReducer(ReduceOperation<S,R> reduceOp)
<S,R extends org.apache.hadoop.io.Writable> ReducerHandle<S,R>	CreateReducersApiWrapper.createLocalReducer(ReduceOperation<S,R> reduceOp, R globalInitialValue)

Uses of ReducerHandle in org.apache.giraph.block_app.reducers.array

Constructor parameters in org.apache.giraph.block_app.reducers.array with type arguments of type ReducerHandle

Constructor and Description
ArrayOfReducers(int count, Int2ObjFunction<ReducerHandle<S,R>> reduceHandleFactory)
ArrayOfReducers(int count, Supplier<ReducerHandle<S,R>> reduceHandleFactory)

Uses of ReducerHandle in org.apache.giraph.block_app.reducers.collect

Classes in org.apache.giraph.block_app.reducers.collect that implement ReducerHandle

Modifier and Type	Class and Description
class	CollectShardedPrimitiveReducerHandle<S> ShardedReducerHandle where we keep a list of reduced values, when primitives are used
class	CollectShardedReducerHandle<S> ShardedReducerHandle where we keep a list of reduced values
class	CollectShardedTuplesOfPrimitivesReducerHandle ShardedReducerHandle where we keep a list of reduced values, and values consist of multiple primitives, so we keep one primitive list for each
class	ShardedReducerHandle<S,R> Reducing values into a list of reducers, randomly, and getting the results of all reducers together