| 原则 | 同构落地、不加工、可追溯 |
|---|---|
| 分区 | 按抽取日期 dt 分区 |
| 写入 | 增量场景按当日分区覆盖 |
| 保留 | 按合规要求保留原始数据 |
ODS 建表
ODS 建表
CREATE TABLE IF NOT EXISTS ods_order_mysql (
id BIGINT COMMENT '订单id',
user_id BIGINT,
total_amount DECIMAL(18,2),
status INT,
create_time STRING,
update_time STRING
) COMMENT '订单表贴源'
PARTITIONED BY (dt STRING COMMENT '抽取日期')
STORED AS ORC;当日分区覆盖写入
当日分区覆盖写入
INSERT OVERWRITE TABLE ods_order_mysql PARTITION (dt='2026-10-11')
SELECT id, user_id, total_amount, status, create_time, update_time
FROM src_order
WHERE update_time >= '2026-10-11 00:00:00';ODS 不做业务规则清洗，能省掉大量数据对不上时无法回源的争论；清洗放 DWD。