org.apache.flink.examples.java.misc

Class PiEstimation.SumReducer

java.lang.Object

org.apache.flink.examples.java.misc.PiEstimation.SumReducer

All Implemented Interfaces:

Serializable, Function, ReduceFunction<Long>

Enclosing class:

PiEstimation

public static final class PiEstimation.SumReducer
extends Object
implements ReduceFunction<Long>

Simply sums up all long values.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SumReducer()

Method Summary

Modifier and Type	Method and Description
Long	reduce(Long value1, Long value2) The core method of ReduceFunction, combining two values into one value of the same type.

Methods inherited from class java.lang.Object

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

Constructor Detail

SumReducer

public SumReducer()

Method Detail

reduce

public Long reduce(Long value1,
                   Long value2)

Description copied from interface: ReduceFunction

The core method of ReduceFunction, combining two values into one value of the same type. The reduce function is consecutively applied to all values of a group until only a single value remains.

Specified by:

reduce in interface ReduceFunction<Long>

Parameters:

value1 - The first value to combine.

value2 - The second value to combine.

Returns:

The combined value of both input values.