| 与普通函数比较 | 使用场景 | |
| 富函数 | 1.可以获取运行环境的上下context(getRuntimeContext由AbstractRichFunction抽象类 提供) 2.生命周期方法（open初始化函数 在每一个thread启动的时候调用一次） 3.管理状态（状态与算子绑定） | 使用Map，Filter.... 算子的时候传入 |
| processFunction | 如果业务比较复杂，通过 Flink 提供这些算子无法满足我们的需求，通过 process 算子直接使用更底层的API（ 上下文、生命周期方法、管理状态、获取事件时间、侧输出流、定时器） | KeyedDataStream 调用 process传入KeyedProcessFunction DataStream 调用 process传入ProcessFunction |
