Prechádzať zdrojové kódy

fix(dim/usr): dim_usr_user_ful_d 移除 is_deleted 过滤(dim 不擅自过滤,下游按需 WHERE)

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
tianyu.chu 3 dní pred
rodič
commit
305a63b

+ 0 - 2
jobs/dim/usr/dim_usr_user_ful_d.sql

@@ -33,7 +33,6 @@ today_base_latest AS (
           AND id IN (SELECT user_id FROM today_changed_users)
     ) t
     WHERE t.rn = 1
-      AND (is_deleted IS NULL OR is_deleted = FALSE)
 ),
 today_cert_latest AS (
     -- 今日变更 user 的最新 cert 版本
@@ -49,7 +48,6 @@ today_cert_latest AS (
           AND user_id IN (SELECT user_id FROM today_changed_users)
     ) t
     WHERE t.rn = 1
-      AND (is_deleted IS NULL OR is_deleted = FALSE)
 ),
 today_dim_rebuild AS (
     -- 今日变更 user 重 join 形成新 dim 行

+ 0 - 2
manual/backfill/20260509_dim_usr_user_ful_d_init.sql

@@ -65,7 +65,6 @@ FROM (
         WHERE dt <= '${dt}'
     ) t
     WHERE t.rn = 1
-      AND (is_deleted IS NULL OR is_deleted = FALSE)
 ) bu
 LEFT JOIN (
     SELECT *
@@ -79,5 +78,4 @@ LEFT JOIN (
         WHERE dt <= '${dt}'
     ) t
     WHERE t.rn = 1
-      AND (is_deleted IS NULL OR is_deleted = FALSE)
 ) ci ON bu.id = ci.user_id;