org.apache.giraph.block_app.reducers.collect

Class CollectShardedTuplesOfPrimitivesReducerHandle

java.lang.Object

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

org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle

All Implemented Interfaces:

ReducerHandle<List<Object>,List<WArrayList>>

public class CollectShardedTuplesOfPrimitivesReducerHandle
extends ShardedReducerHandle<List<Object>,List<WArrayList>>

ShardedReducerHandle where we keep a list of reduced values, and values consist of multiple primitives, so we keep one primitive list for each

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle BroadcastHandle for CollectShardedTuplesOfPrimitivesReducerHandle
static class	CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast Reduce broadcast wrapper

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
CollectShardedTuplesOfPrimitivesReducerHandle(CreateReducersApi reduceApi, Class<?>... valueClasses)

Method Summary

Modifier and Type	Method and Description
BroadcastHandle<List<WArrayList>>	createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>> broadcasts)
List<WArrayList>	createLists(int size)
ReduceOperation<List<Object>,KryoWritableWrapper<List<WArrayList>>>	createReduceOperation()
List<WArrayList>	createReduceResult(MasterGlobalCommUsage master)
List<Object>	createSingleValue()

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

CollectShardedTuplesOfPrimitivesReducerHandle

public CollectShardedTuplesOfPrimitivesReducerHandle(CreateReducersApi reduceApi,
                                                     Class<?>... valueClasses)

Method Detail

createSingleValue

public List<Object> createSingleValue()

createReduceOperation

public ReduceOperation<List<Object>,KryoWritableWrapper<List<WArrayList>>> createReduceOperation()

Specified by:

createReduceOperation in class ShardedReducerHandle<List<Object>,List<WArrayList>>

createReduceResult

public List<WArrayList> createReduceResult(MasterGlobalCommUsage master)

Overrides:

createReduceResult in class ShardedReducerHandle<List<Object>,List<WArrayList>>

createLists

public List<WArrayList> createLists(int size)

createBroadcastHandle

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

Overrides:

createBroadcastHandle in class ShardedReducerHandle<List<Object>,List<WArrayList>>