| 合并 | 按自然键取末条 |
|---|---|
| 生效日 | 统一取批次日 |
| 顺序 | row_number 取 rn=1 |
窗口取末条
窗口取末条
SELECT * FROM (
SELECT s.*, row_number() OVER (PARTITION BY customer_id ORDER BY update_ts DESC) AS rn
FROM stg_customer
WHERE update_ts >= :w_start AND update_ts < :w_end
) t WHERE rn = 1;若业务要求「一天一版本」，则按天分桶推进，并接受多版本形态。