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() Look at ReduceOperation.createValue.
void	reduce(List<S> reduceInto, S value) Look at ReduceOperation.reduce.
void	reduceMerge(List<S> reduceInto, List<S> toReduce) Look at ReduceOperation.reduceMerge.

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()

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.createValue.

Specified by:

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

Returns:

Neutral value

reduce

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

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.reduce.

Specified by:

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

Parameters:

reduceInto - Partial value into which to reduce and store the result

value - Single value to be reduced

reduceMerge

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

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.reduceMerge.

Specified by:

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

Parameters:

reduceInto - Partial value into which to reduce and store the result

toReduce - Partial value to be reduced

createList

public List<S> createList()