Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.aggregation |
Class and Description |
---|
AggregationFunction
Holder class for aggregation types that can be used on a windowed stream or keyed stream.
|
Class and Description |
---|
AggregationFunction
Holder class for aggregation types that can be used on a windowed stream or keyed stream.
|
AggregationFunction.AggregationType
Aggregation types that can be used on a windowed stream or keyed stream.
|
Comparator
Internal comparator implementation, for use with
ComparableAggregator . |
SumFunction
Internal function for summing up contents of fields.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.