org.apache.giraph.block_app.reducers.collect

Class ShardedReducerHandle<S,R>

java.lang.Object

org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle<S,R>

Type Parameters:

S - Single value type

R - Reduced value type

All Implemented Interfaces:

ReducerHandle<S,R>

Direct Known Subclasses:

CollectShardedPrimitiveReducerHandle, CollectShardedReducerHandle, CollectShardedTuplesOfPrimitivesReducerHandle

public abstract class ShardedReducerHandle<S,R>
extends Object
implements ReducerHandle<S,R>

Reducing values into a list of reducers, randomly, and getting the results of all reducers together

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ShardedReducerHandle.ShardedBroadcastHandle Broadcast for ShardedReducerHandle

Field Summary

Fields

Modifier and Type	Field and Description
protected TransientRandom	random
protected static int	REDUCER_COUNT
protected ArrayOfHandles.ArrayOfReducers<S,KryoWritableWrapper<R>>	reducers

Constructor Summary

Constructors

Constructor and Description
ShardedReducerHandle()

Method Summary

Modifier and Type	Method and Description
BroadcastHandle<R>	broadcastValue(BlockMasterApi masterApi) Broadcast reduced value from master
BroadcastHandle<R>	createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts)
abstract ReduceOperation<S,KryoWritableWrapper<R>>	createReduceOperation()
R	createReduceResult(MasterGlobalCommUsage master)
R	getReducedValue(MasterGlobalCommUsage master) Get reduced value
void	reduce(S value) Reduce single value
void	register(CreateReducersApi reduceApi)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

REDUCER_COUNT

protected static final int REDUCER_COUNT

See Also:

Constant Field Values

random

protected final TransientRandom random

reducers

protected ArrayOfHandles.ArrayOfReducers<S,KryoWritableWrapper<R>> reducers

Constructor Detail

ShardedReducerHandle

public ShardedReducerHandle()

Method Detail

register

public final void register(CreateReducersApi reduceApi)

reduce

public final void reduce(S value)

Description copied from interface: ReducerHandle

Reduce single value

Specified by:

reduce in interface ReducerHandle<S,R>

getReducedValue

public final R getReducedValue(MasterGlobalCommUsage master)

Description copied from interface: ReducerHandle

Get reduced value

Specified by:

getReducedValue in interface ReducerHandle<S,R>

createReduceOperation

public abstract ReduceOperation<S,KryoWritableWrapper<R>> createReduceOperation()

createReduceResult

public R createReduceResult(MasterGlobalCommUsage master)

createBroadcastHandle

public BroadcastHandle<R> createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts)

broadcastValue

public final BroadcastHandle<R> broadcastValue(BlockMasterApi masterApi)

Description copied from interface: ReducerHandle

Broadcast reduced value from master

Specified by:

broadcastValue in interface ReducerHandle<S,R>

Returns:

Handle to the broadcasted value.