Class LongSummaryAggregator.MinLongAggregator
- java.lang.Object
-
- org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MinLongAggregator
-
- All Implemented Interfaces:
Serializable,Aggregator<Long,Long>
- Enclosing class:
- LongSummaryAggregator
public static class LongSummaryAggregator.MinLongAggregator extends Object implements Aggregator<Long,Long>
Aggregator for min operation.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MinLongAggregator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaggregate(Long value)Add a value to the current aggregation.voidcombine(Aggregator<Long,Long> other)Combine two aggregations of the same type.Longresult()Provide the final result of the aggregation.
-
-
-
Method Detail
-
aggregate
public void aggregate(Long value)
Description copied from interface:AggregatorAdd a value to the current aggregation.- Specified by:
aggregatein interfaceAggregator<Long,Long>
-
combine
public void combine(Aggregator<Long,Long> other)
Description copied from interface:AggregatorCombine two aggregations of the same type.(Implementations will need to do an unchecked cast).
- Specified by:
combinein interfaceAggregator<Long,Long>
-
result
public Long result()
Description copied from interface:AggregatorProvide the final result of the aggregation.- Specified by:
resultin interfaceAggregator<Long,Long>
-
-