public static class GroupedProcessingTimeWindowExample.SummingReducer extends Object implements ReduceFunction<Tuple2<Long,Long>>
Constructor and Description |
---|
SummingReducer() |
public Tuple2<Long,Long> reduce(Tuple2<Long,Long> value1, Tuple2<Long,Long> value2)
ReduceFunction
reduce
in interface ReduceFunction<Tuple2<Long,Long>>
value1
- The first value to combine.value2
- The second value to combine.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.