| 粒度 | 一个流程实例一行（订单/工单） |
|---|---|
| 结构 | 多个时间戳列加当前阶段 |
| 更新 | 阶段推进时更新同一行 |
| 用途 | 流转时长、阶段漏斗、超时监控 |
订单累积快照
订单累积快照
CREATE TABLE fact_order_flow (
order_id BIGINT, user_sk BIGINT,
create_ts TIMESTAMP, pay_ts TIMESTAMP, ship_ts TIMESTAMP, sign_ts TIMESTAMP,
current_stage STRING
) PARTITIONED BY (dt STRING);
UPDATE fact_order_flow SET pay_ts = '2026-10-11 10:20:00', current_stage = 'paid'
WHERE order_id = 1001 AND pay_ts IS NULL;引擎不支持 UPDATE 时（如部分 Hive 表）用新增分区加合并时取最新的方式模拟，但要保证合并逻辑幂等。