org.apache.giraph.block_app.reducers.collect

Class CollectTuplesOfPrimitivesReduceOperation

java.lang.Object

org.apache.giraph.reducers.impl.KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

org.apache.giraph.block_app.reducers.collect.CollectTuplesOfPrimitivesReduceOperation

All Implemented Interfaces:

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

public class CollectTuplesOfPrimitivesReduceOperation
extends KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

Collect tuples of primitive values reduce operation

Constructor Summary

Constructors

Constructor and Description
CollectTuplesOfPrimitivesReduceOperation() For reflection only
CollectTuplesOfPrimitivesReduceOperation(List<PrimitiveTypeOps> typeOpsList)

Method Summary

Modifier and Type	Method and Description
List<WArrayList>	createValue() Look at ReduceOperation.createValue.
void	readFields(DataInput in)
void	reduce(List<WArrayList> reduceInto, List<Object> value) Look at ReduceOperation.reduce.
void	reduceMerge(List<WArrayList> reduceInto, List<WArrayList> toReduce) Look at ReduceOperation.reduceMerge.
void	write(DataOutput out)

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

createInitialValue, reduce, reduceMerge

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectTuplesOfPrimitivesReduceOperation

public CollectTuplesOfPrimitivesReduceOperation()

For reflection only

CollectTuplesOfPrimitivesReduceOperation

public CollectTuplesOfPrimitivesReduceOperation(List<PrimitiveTypeOps> typeOpsList)

Method Detail

createValue

public List<WArrayList> createValue()

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.createValue.

Specified by:

createValue in class KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

Returns:

Neutral value

reduce

public void reduce(List<WArrayList> reduceInto,
                   List<Object> value)

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.reduce.

Specified by:

reduce in class KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

Parameters:

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

value - Single value to be reduced

reduceMerge

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

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.reduceMerge.

Specified by:

reduceMerge in class KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

Parameters:

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

toReduce - Partial value to be reduced

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Overrides:

write in class KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Overrides:

readFields in class KryoWrappedReduceOperation<List<Object>,List<WArrayList>>

Throws:

IOException