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()
void	readFields(DataInput in)
void	reduce(List<WArrayList> reduceInto, List<Object> value)
void	reduceMerge(List<WArrayList> reduceInto, List<WArrayList> toReduce)
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()

Specified by:

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

reduce

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

Specified by:

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

reduceMerge

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

Specified by:

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

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