org.apache.giraph.benchmark

Class ReducersBenchmark.TestLongSumReducer

java.lang.Object

org.apache.giraph.reducers.ReduceSameTypeOperation<org.apache.hadoop.io.LongWritable>

org.apache.giraph.benchmark.ReducersBenchmark.TestLongSumReducer

All Implemented Interfaces:

ReduceOperation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>, org.apache.hadoop.io.Writable

Enclosing class:

ReducersBenchmark

public static class ReducersBenchmark.TestLongSumReducer
extends ReduceSameTypeOperation<org.apache.hadoop.io.LongWritable>

LongSumReducer

Field Summary

Fields

Modifier and Type	Field and Description
static ReducersBenchmark.TestLongSumReducer	INSTANCE Singleton

Constructor Summary

Constructors

Constructor and Description
TestLongSumReducer()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.LongWritable	createInitialValue() Return new reduced value which is neutral to reduce operation.
void	readFields(DataInput in)
org.apache.hadoop.io.LongWritable	reduce(org.apache.hadoop.io.LongWritable curValue, org.apache.hadoop.io.LongWritable valueToReduce) Add a new value.
void	write(DataOutput out)

Methods inherited from class org.apache.giraph.reducers.ReduceSameTypeOperation

reduceMerge

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final ReducersBenchmark.TestLongSumReducer INSTANCE

Singleton

Constructor Detail

TestLongSumReducer

public TestLongSumReducer()

Method Detail

createInitialValue

public org.apache.hadoop.io.LongWritable createInitialValue()

Description copied from interface: ReduceOperation

Return new reduced value which is neutral to reduce operation.

Returns:

Neutral value

reduce

public org.apache.hadoop.io.LongWritable reduce(org.apache.hadoop.io.LongWritable curValue,
                                                org.apache.hadoop.io.LongWritable valueToReduce)

Description copied from interface: ReduceOperation

Add a new value. Needs to be commutative and associative Commonly, returned value should be same as curValue argument.

Parameters:

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

valueToReduce - Single value to be reduced

Returns:

reduced value

readFields

public void readFields(DataInput in)
                throws IOException

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Throws:

IOException