企业官网建设流程全解析

本文重点

在前面的课程中我们学习了基于DataStream的各种操作，比如聚合、转换、窗口等等，我们可以利用flink定义的各种算子来完成各种不同的任务。在DataStream的下一层就是基本处理函数（ProcessFunction），在这一层没有了算子的概念，我们可以在这一层接触到很多底层的逻辑，可以脱离FLink为我们设置的算子框架，为所欲为，本文对此进行学习。

Flink框架中的处理函数

在FLink中，不同类型的流可以调用.process()方法传入处理函数，不同的处理函数之间会有一些差异：

（1）ProcessFunction 最基本的处理函数，基于 DataStream 直接调用.process()时作为参数传入。

（2）KeyedProcessFunction 对流按键分区后的处理函数，基于KeyedStream 调用.process()时作为参数传入。在 Flink 中，只有按键分区流KeyedStream才支持设置定时器的操作。

（3）ProcessWindowFunction 开窗之后的处理函数，基于 WindowedStream 调用.process()时作 为参数传入。

（4）ProcessAllWindowFunction 开窗之后的处理函数，基于 AllWindowedStream 调用.process()时作为参数传入。

（5