org.apache.giraph.block_app.reducers.collect

Class CollectPrimitiveReduceOperation<S>

java.lang.Object

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

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

Type Parameters:

S - Primitive Writable type, which has its type ops

All Implemented Interfaces:

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

public class CollectPrimitiveReduceOperation<S>
extends KryoWrappedReduceOperation<S,WArrayList<S>>

Collect primitive values reduce operation

Constructor Summary

Constructors

Constructor and Description
CollectPrimitiveReduceOperation() For reflection only
CollectPrimitiveReduceOperation(PrimitiveTypeOps<S> typeOps)

Method Summary

Modifier and Type	Method and Description
WArrayList<S>	createList()
WArrayList<S>	createValue() Look at ReduceOperation.createValue.
void	readFields(DataInput in)
void	reduce(WArrayList<S> reduceInto, S value) Look at ReduceOperation.reduce.
void	reduceMerge(WArrayList<S> reduceInto, WArrayList<S> 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

CollectPrimitiveReduceOperation

public CollectPrimitiveReduceOperation()

For reflection only

CollectPrimitiveReduceOperation

public CollectPrimitiveReduceOperation(PrimitiveTypeOps<S> typeOps)

Method Detail

createValue

public WArrayList<S> createValue()

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.createValue.

Specified by:

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

Returns:

Neutral value

reduce

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

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.reduce.

Specified by:

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

Parameters:

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

value - Single value to be reduced

reduceMerge

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

Description copied from class: KryoWrappedReduceOperation

Look at ReduceOperation.reduceMerge.

Specified by:

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

Parameters:

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

toReduce - Partial value to be reduced

createList

public WArrayList<S> createList()

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Overrides:

write in class KryoWrappedReduceOperation<S,WArrayList<S>>

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<S,WArrayList<S>>

Throws:

IOException