Class PiEstimation.SumReducer

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.ReduceFunction<Long>
    Enclosing class:
    PiEstimation

    public static final class PiEstimation.SumReducer
    extends Object
    implements org.apache.flink.api.common.functions.ReduceFunction<Long>
    Simply sums up all long values.
    See Also:
    Serialized Form
    • Constructor Detail

      • SumReducer

        public SumReducer()
    • Method Detail

      • reduce

        public Long reduce​(Long value1,
                           Long value2)
        Specified by:
        reduce in interface org.apache.flink.api.common.functions.ReduceFunction<Long>