org.apache.giraph.block_app.reducers.collect

Class CollectShardedReducerHandle<S>

java.lang.Object

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

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

Type Parameters:

S - Single value type

All Implemented Interfaces:

ReducerHandle<S,List<S>>

public class CollectShardedReducerHandle<S>
extends ShardedReducerHandle<S,List<S>>

ShardedReducerHandle where we keep a list of reduced values

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CollectShardedReducerHandle.CollectShardedBroadcastHandle BroadcastHandle for CollectShardedReducerHandle

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
CollectShardedReducerHandle(CreateReducersApi reduceApi)

Method Summary

Modifier and Type	Method and Description
BroadcastHandle<List<S>>	createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<S>>> broadcasts)
List<S>	createList(int size)
ReduceOperation<S,KryoWritableWrapper<List<S>>>	createReduceOperation()
List<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

CollectShardedReducerHandle

public CollectShardedReducerHandle(CreateReducersApi reduceApi)

Method Detail

createReduceOperation

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

Specified by:

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

createReduceResult

public List<S> createReduceResult(MasterGlobalCommUsage master)

Overrides:

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

createList

public List<S> createList(int size)

createBroadcastHandle

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

Overrides:

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