org.apache.giraph.block_app.reducers.collect

Class CollectReduceOperation<S>

java.lang.Object

org.apache.giraph.reducers.impl.KryoWrappedReduceOperation<S,List<S>>

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

Type Parameters:

S - Type of values to collect

All Implemented Interfaces:

ReduceOperation<S,KryoWritableWrapper<List<S>>>, org.apache.hadoop.io.Writable

public class CollectReduceOperation<S>
extends KryoWrappedReduceOperation<S,List<S>>

Collect values reduce operation

Constructor Summary

Constructors

Constructor and Description
CollectReduceOperation()

Method Summary

Modifier and Type	Method and Description
List<S>	createList()
List<S>	createValue()
void	reduce(List<S> reduceInto, S value)
void	reduceMerge(List<S> reduceInto, List<S> toReduce)

Methods inherited from class org.apache.giraph.reducers.impl.KryoWrappedReduceOperation

createInitialValue, readFields, reduce, reduceMerge, write

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectReduceOperation

public CollectReduceOperation()

Method Detail

createValue

public List<S> createValue()

Specified by:

createValue in class KryoWrappedReduceOperation<S,List<S>>

reduce

public void reduce(List<S> reduceInto,
                   S value)

Specified by:

reduce in class KryoWrappedReduceOperation<S,List<S>>

reduceMerge

public void reduceMerge(List<S> reduceInto,
                        List<S> toReduce)

Specified by:

reduceMerge in class KryoWrappedReduceOperation<S,List<S>>

createList

public List<S> createList()