| 事件时间 | 数据自带的发生时间，从记录中提取 |
|---|---|
| 处理时间 | 引擎本地时钟，实现简单但不可复现 |
| 摄入时间 | 进入引擎系统的时刻，介于两者之间 |
Flink SQL 声明事件时间
Flink SQL 声明事件时间
CREATE TABLE orders (
order_id STRING,
amount DECIMAL(10,2),
ts TIMESTAMP(3),
WATERMARK FOR ts AS ts - INTERVAL '5' SECOND
) WITH ('connector' = 'kafka', ...);用处理时间做统计时，重跑同一批数据会得到不同结果；对外口径指标优先用事件时间。