知识卡片
水位线生成的周期性与非周期性模式
内容
生成水位线有两种触发方式:周期性模式按固定时间间隔(比如每200毫秒)统一生成一次水位线,不需要每条数据都参与判断,开销小、实现简单,是大多数场景的默认选择;非周期性(标点式)模式则根据事件数据本身的某个特征来决定要不要生成水位线,比如只在遇到特定标记的数据时才生成,能做到更精确、更及时地反映进度,但需要在每条数据到达时都执行一次判断逻辑,开销更高。这是一个典型的”采样频率”取舍:周期性用固定节奏换低开销,牺牲的是水位线更新的及时性;非周期性用逐条判断换精确性,代价是处理路径上多了一层计算。
参考来源
《Flink入门与实战》第3章《时间和窗口》