org.apache.giraph.block_app.reducers.collect

Class CollectShardedPrimitiveReducerHandle<S>

java.lang.Object

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

org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle<S>

Type Parameters:

S - Single value type

All Implemented Interfaces:

ReducerHandle<S,WArrayList<S>>

public class CollectShardedPrimitiveReducerHandle<S>
extends ShardedReducerHandle<S,WArrayList<S>>

ShardedReducerHandle where we keep a list of reduced values, when primitives are used

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle Broadcast handle for CollectShardedPrimitiveReducerHandle

Nested classes/interfaces inherited from class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle

ShardedReducerHandle.ShardedBroadcastHandle

Field Summary

Fields inherited from class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle

random, REDUCER_COUNT, reducers

Constructor Summary

Constructors

Constructor and Description
CollectShardedPrimitiveReducerHandle(CreateReducersApi reduceApi, Class<S> valueClass)

Method Summary

Modifier and Type	Method and Description
BroadcastHandle<WArrayList<S>>	createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts)
WArrayList<S>	createList(int size)
ReduceOperation<S,KryoWritableWrapper<WArrayList<S>>>	createReduceOperation()
WArrayList<S>	createReduceResult(MasterGlobalCommUsage master)

Methods inherited from class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle

broadcastValue, getReducedValue, reduce, register

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectShardedPrimitiveReducerHandle

public CollectShardedPrimitiveReducerHandle(CreateReducersApi reduceApi,
                                            Class<S> valueClass)

Method Detail

createReduceOperation

public ReduceOperation<S,KryoWritableWrapper<WArrayList<S>>> createReduceOperation()

Specified by:

createReduceOperation in class ShardedReducerHandle<S,WArrayList<S>>

createReduceResult

public WArrayList<S> createReduceResult(MasterGlobalCommUsage master)

Overrides:

createReduceResult in class ShardedReducerHandle<S,WArrayList<S>>

createList

public WArrayList<S> createList(int size)

createBroadcastHandle

public BroadcastHandle<WArrayList<S>> createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts)

Overrides:

createBroadcastHandle in class ShardedReducerHandle<S,WArrayList<S>>