| 窗口 | 按业务容忍度设定 |
|---|---|
| 窗口内 | 重跑当日分区 |
| 超窗 | 修正批次 |
| 回刷 | 局部重算受影响日期 |
迟到判定
迟到判定
SELECT order_id, pay_amt, create_time
FROM stg_order
WHERE create_time < '2026-10-12 00:00:00' -- 业务上属于昨日
AND etl_load_time >= '2026-10-12 00:00:00'; -- 今日才到迟到数据的处理策略要写进口径文档:延迟入账还是回溯调整历史。
上游数据迟到会产生跨天补数:给迟到设定容忍窗口(如 2 小时),窗口内重跑当日;超窗数据进入修正批次并触发受影响日期的局部回刷。
| 窗口 | 按业务容忍度设定 |
|---|---|
| 窗口内 | 重跑当日分区 |
| 超窗 | 修正批次 |
| 回刷 | 局部重算受影响日期 |
SELECT order_id, pay_amt, create_time
FROM stg_order
WHERE create_time < '2026-10-12 00:00:00' -- 业务上属于昨日
AND etl_load_time >= '2026-10-12 00:00:00'; -- 今日才到