第 193 题：窗口计算的触发策略，处理时间与事件时间的选择？
题目
窗口计算的触发策略，处理时间与事件时间的选择？
完整讲解
一、处理时间 vs 事件时间
处理时间（Processing Time）：数据被算子处理的当前机器时间，简单、无延迟问题，但与事件真实发生顺序无关，重放或延迟会导致结果不一致。事件时间（Event Time）：数据自带业务发生时间（如日志时间戳），窗口与乱序按事件时间计算，结果可复现、语义清晰，但需处理乱序与延迟。
二、窗口触发的选择
- 处理时间窗口：按「何时被处理」划分窗口，到达即触发，无需 watermark；适合对一致性要求低、只要实时性的场景（如监控大盘）。
- 事件时间窗口：按「事件时间」划分窗口，需 Watermark 推进事件时间；触发条件通常为：watermark 超过窗口结束时间 + 允许的延迟（Allowed Lateness）策略。结果确定性、可重复，适合计费、对账、离线对比。
三、触发策略
- 默认：Flink 事件时间窗口在 watermark ≥ 窗口 end 时触发一次；若设置 Allowed Lateness，在延迟数据到达时可能再次触发（late output）。
- 自定义 Trigger：可基于计数、处理时间、或「watermark + 条件」做复杂触发（如会话窗口、早期触发 + 最终触发）。选择取决于业务：要早期近似结果用早期触发；要最终一致用 watermark 触发 + 可选 late 更新。
面试要点
- 能区分处理时间与事件时间，及各自适用场景（实时性 vs 确定性）。
- 能说清事件时间窗口的触发：watermark、Allowed Lateness、late 输出；能简述 Trigger 的作用。
- 能说明何时选处理时间、何时选事件时间（一致性、乱序、延迟要求）。
记忆要点
- 处理时间=处理时刻，简单但非确定性；事件时间=业务时间，需 watermark、可重复。
- 事件时间触发：watermark ≥ 窗口 end + Allowed Lateness；可自定义 Trigger（早期/最终）。