Flink之ProcessFunction API(底层 API)_keyedcoprocessfunction 和 keyedprocesssfunction的区别-CSDN博客

网站介绍:文章浏览阅读1.2k次。ProcessFunction API一、KeyedProcessFunction二、TimerService 和 定时器(Timers)三、侧输出流(SideOutput)四、CoProcessFunction我们之前学习的转换算子是无法访问事件的时间戳信息和水位线信息的。而这在一些应用场景下,极为重要。例如 MapFunction 这样的 map 转换算子就无法访问时间戳或者当前事件的事件时间。基于此,DataStream API 提供了一系列的 Low-Level 转换算子。可以访问时间戳、wat_keyedcoprocessfunction 和 keyedprocesssfunction的区别