| 延迟 | 分钟级 + 抖动 |
|---|---|
| 乱序 | watermark 窗口 |
| 对账 | 有界差异可解释 |
实时窗口计数
实时窗口计数
-- Flink：5 分钟滚动窗口支付金额
SELECT window_start, window_end, sum(pay_amt) AS amt
FROM TABLE(TUMBLE(TABLE pay_stream, DESCRIPTOR(event_ts), INTERVAL '5' MINUTES))
GROUP BY window_start, window_end;实时看趋势、离线定口径：两者数字必须能解释，不能互相打架。