Class LongSummaryAggregator
- java.lang.Object
-
- org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator<Long>
-
- org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator
-
- All Implemented Interfaces:
Serializable,Aggregator<Long,NumericColumnSummary<Long>>
@Internal public class LongSummaryAggregator extends NumericSummaryAggregator<Long>
Aggregator that can handle Long types.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classLongSummaryAggregator.MaxLongAggregatorAggregator for max operation.static classLongSummaryAggregator.MinLongAggregatorAggregator for min operation.
-
Constructor Summary
Constructors Constructor Description LongSummaryAggregator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Aggregator<Long,Long>initMax()protected Aggregator<Long,Long>initMin()protected Aggregator<Long,Long>initSum()protected booleanisInfinite(Long number)protected booleanisNan(Long number)-
Methods inherited from class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator
aggregate, combine, result
-
-
-
-
Method Detail
-
initMin
protected Aggregator<Long,Long> initMin()
- Specified by:
initMinin classNumericSummaryAggregator<Long>
-
initMax
protected Aggregator<Long,Long> initMax()
- Specified by:
initMaxin classNumericSummaryAggregator<Long>
-
initSum
protected Aggregator<Long,Long> initSum()
- Specified by:
initSumin classNumericSummaryAggregator<Long>
-
isNan
protected boolean isNan(Long number)
- Specified by:
isNanin classNumericSummaryAggregator<Long>
-
isInfinite
protected boolean isInfinite(Long number)
- Specified by:
isInfinitein classNumericSummaryAggregator<Long>
-
-