|
|
@@ -4,10 +4,12 @@
|
|
|
-- 目的:raw → ods 全量快照 —— 读 raw dt=${dt} 全量(一行一 id = 当前态),CAST 落 ods ful_d dt=${dt}
|
|
|
-- 状态:[草案]
|
|
|
-- 备注:sched=T,${dt}=T-1;维度全量快照模型(无 seed / 无 merge / 无 dedup,PG id 唯一)见 kb/24 §1.2.2;
|
|
|
--- 保留近 7 天:INSERT 前 DROP 掉 ${rdt}=T-8 一个分区(DS 传 rdt=$[yyyyMMdd-8],手动跑 -p rdt=<T-8>);
|
|
|
+-- 保留近 7 天:INSERT 前 DROP 掉 ${wdt}=T-8 一个分区,raw / ods 一并 drop(raw 的 drop 也收进本 ods
|
|
|
+-- 任务,DataX ini 不便 drop);DS 传 wdt=$[yyyyMMdd-8],手动跑 -p wdt=<T-8>;
|
|
|
-- 静态分区写入 PARTITION(dt='${dt}'):源=raw、目标=ods,不同表无读写冲突。
|
|
|
|
|
|
-ALTER TABLE ods.ods_prd_panini_checklist_base_info_ful_d DROP IF EXISTS PARTITION (dt='${rdt}');
|
|
|
+ALTER TABLE raw.raw_prd_panini_checklist_base_info_ful_d DROP IF EXISTS PARTITION (dt='${wdt}');
|
|
|
+ALTER TABLE ods.ods_prd_panini_checklist_base_info_ful_d DROP IF EXISTS PARTITION (dt='${wdt}');
|
|
|
|
|
|
INSERT OVERWRITE TABLE ods.ods_prd_panini_checklist_base_info_ful_d PARTITION (dt='${dt}')
|
|
|
SELECT
|