flink 所有的窗口函数
时间: 2023-11-07 19:29:36 浏览: 93
窗口函数集
Flink 支持多种类型的窗口函数,以下是一些常用的窗口函数:
1. ReduceFunction:对窗口中的元素进行 reduce 操作,返回一个单一的结果值。
2. AggregateFunction:将窗口中的元素聚合成一个列表或者集合,并返回一个新的聚合值。
3. ProcessWindowFunction:对窗口中的元素进行处理,并生成一个或多个输出结果。
4. WindowFunction:对窗口中的元素进行处理,并生成一个输出结果。
5. AllWindowFunction:对窗口中的所有元素进行处理,并生成一个输出结果。
6. FoldFunction:将窗口中的元素递归地折叠成一个结果。
7. ApplyFunction:应用一个自定义的函数来处理窗口中的元素。
以上是 Flink 中较为常见的窗口函数,具体使用可以根据需求选择不同的窗口函数。
阅读全文