diff --git a/THC/01 dm_thc_pack_property.sql b/THC/01 dm_thc_pack_property.sql index 98678e8..abf9e80 100644 --- a/THC/01 dm_thc_pack_property.sql +++ b/THC/01 dm_thc_pack_property.sql @@ -135,7 +135,7 @@ from dwd.dwd_gnd_dept_pack_property -- create or replace table dm.dm_chc_pack_property -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_chc_pack_property' -- as --- insert overwrite table dm.dm_thc_pack_property +insert overwrite table dm.dm_thc_pack_property WITH dedup_l AS ( SELECT *, ROW_NUMBER() OVER (PARTITION BY iqvia_pack_code ORDER BY iqvia_pack_code) AS rn @@ -228,4 +228,4 @@ SELECT from_utc_timestamp(current_timestamp(),'UTC+8') as ETL_UPDATE_DT FROM dedup_l l LEFT JOIN dedup_r r - ON l.iqvia_pack_code = r.PACK_COD \ No newline at end of file + ON l.iqvia_pack_code = r.PACK_COD