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