【Flink】Flink的处理函数、TopN案例和侧输出流_flink top-CSDN博客

网站介绍:文章浏览阅读1.9k次。在更底层,我们可以不定义任何具体的算子(比如 map,filter,或者 window),而只是提 炼出一个统一的“处理”(process)操作——它是所有转换算子的一个概括性的表达,可以自 定义处理逻辑,所以这一层接口就被叫作“处理函数”(process function)。 在处理函数中,我们直面的就是数据流中最基本的元素:数据事件(event)、状态(state)以及时间(time)。这就相当于对流有了完全的控制权。一、基本处理函数(ProcessF..._flink top