Flink函数父类有哪些
时间: 2024-01-15 09:03:01 浏览: 115
实现一个简单的HTTP请求的Flink UDF函数
Flink函数父类有以下几种:
1. RichFunction:所有 Flink 函数的父类,提供了一些钩子方法,可以在函数的生命周期中执行一些操作,例如打开/关闭连接、获取运行时上下文等。
2. MapFunction:将输入数据转换为输出数据的函数,可以将一个输入数据映射成一个输出数据,也可以将一个输入数据映射成多个输出数据。
3. FlatMapFunction:将输入数据转换为输出数据的函数,可以将一个输入数据映射成多个输出数据。
4. FilterFunction:过滤输入数据的函数,可以根据一定的条件过滤数据。
5. ReduceFunction:对输入数据进行聚合计算的函数,可以将多个输入数据聚合成一个输出数据。
6. AggregateFunction:对输入数据进行聚合计算的函数,可以将多个输入数据聚合成一个输出数据,并且可以返回聚合过程中的中间状态。
7. KeySelector:将输入数据中的某个字段作为 Key 进行分组的函数,用于分组聚合操作。
8. WindowFunction:对窗口中的数据进行聚合计算的函数,可以将窗口中的多个输入数据聚合成一个输出数据。
阅读全文