1 函数类（ Function Classes ）
Flink 暴露了所有 udf 函数的接口 ( 实现方式为接口或者抽象类 ) 。例如
MapFunction, FilterFunction, ProcessFunction 等等。
下面例子实现了 FilterFunction 接口：

 

 还可以将函数实现成匿名类

 我们 filter 的字符串"flink"还可以当作参数传进去。

 2 匿名函数（Lambda Functions）

 3 富函数（Rich Functions）

“富函数”是 DataStream API 提供的一个函数类的接口，所有 Flink 函数类都
有其 Rich 版本。它与常规函数的不同在于，可以获取运行环境的上下文，并拥有一
些生命周期方法，所以可以实现更复杂的功能。
⚫ RichMapFunction
⚫ RichFlatMapFunction
⚫ RichFilterFunction
⚫ …
Rich Function 有一个生命周期的概念。典型的生命周期方法有：
⚫ open() 方法是 rich function 的初始化方法，当一个算子例如 map 或者 filter
被调用之前 open() 会被调用。
⚫ close() 方法是生命周期中的最后一个调用的方法，做一些清理工作。
⚫ getRuntimeContext() 方法提供了函数的 RuntimeContext 的一些信息，例如函
数执行的并行度，任务的名字，以及 state 状态

# flink # 大数据 # big data
Logo
大数据技术专区

大数据从业者之家,一起探索大数据的无限可能！

更多推荐

SQL：数据去重的三种方法

SQL中去除重复数据

avatar 大数据技术专区
cover

一文通览腾讯云大数据ES、数据湖计算、云数据仓库产品新版本技术创新

avatar 大数据技术专区
cover

【大数据实训】基于Hive的北京市天气系统分析报告(二)

avatar 大数据技术专区