Class ShortSummaryAggregator
- java.lang.Object
-
- org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator<Short>
-
- org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator
-
- All Implemented Interfaces:
Serializable,Aggregator<Short,NumericColumnSummary<Short>>
@Internal public class ShortSummaryAggregator extends NumericSummaryAggregator<Short>
Aggregator that can handle Short types.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classShortSummaryAggregator.MaxShortAggregatorAggregator for max operation.static classShortSummaryAggregator.MinShortAggregatorAggregator for min operation.static classShortSummaryAggregator.SumShortAggregatorAggregator for sum operation.
-
Constructor Summary
Constructors Constructor Description ShortSummaryAggregator()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Aggregator<Short,Short>initMax()protected Aggregator<Short,Short>initMin()protected Aggregator<Short,Short>initSum()protected booleanisInfinite(Short number)protected booleanisNan(Short number)static Shortmax(Short a, Short b)Like Math.max() except for shorts.static Shortmin(Short a, Short b)Like Math.min() except for shorts.-
Methods inherited from class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator
aggregate, combine, result
-
-
-
-
Method Detail
-
initMin
protected Aggregator<Short,Short> initMin()
- Specified by:
initMinin classNumericSummaryAggregator<Short>
-
initMax
protected Aggregator<Short,Short> initMax()
- Specified by:
initMaxin classNumericSummaryAggregator<Short>
-
initSum
protected Aggregator<Short,Short> initSum()
- Specified by:
initSumin classNumericSummaryAggregator<Short>
-
isNan
protected boolean isNan(Short number)
- Specified by:
isNanin classNumericSummaryAggregator<Short>
-
isInfinite
protected boolean isInfinite(Short number)
- Specified by:
isInfinitein classNumericSummaryAggregator<Short>
-
-