ads_trd_group_funnel_create.sql 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. -- 作者:tianyu.chu
  2. -- 日期:2026-06-21(2026-06-23 拆表重构)
  3. -- 工单:(无)
  4. -- 目的:拼团转化漏斗 ADS,按"同步 PG 的更新周期"拆两张宽表(对齐 kb/26 §1.3 按更新周期拆表)
  5. -- 备注:① _daily 昨日逐日,每日增量 insert 新 dt(历史不可变,累积,喂趋势)
  6. -- ② _rolling 近7/30天,每日 INSERT OVERWRITE 覆盖最新 1 行(滚动值;窗口去重无法由日 UV 加工,
  7. -- 必须独立 distinct;历史可从 ods 重算,MVP 不留)
  8. -- 聚合 UV、非路径漏斗(层间近似);登录用户口径;窗口入字段名(kb/40 §3.7)
  9. CREATE DATABASE IF NOT EXISTS ads;
  10. -- ① 昨日逐日(增量,分区累积)
  11. CREATE TABLE IF NOT EXISTS ads.ads_trd_group_funnel_daily (
  12. uv_start BIGINT COMMENT '启动UV($AppStart,登录用户)',
  13. uv_show BIGINT COMMENT '曝光UV(GroupShow)',
  14. uv_detail BIGINT COMMENT '拼团详情UV(ClickGroup)',
  15. uv_order BIGINT COMMENT '下单UV(GroupPayOrderConfirm)',
  16. uv_paid BIGINT COMMENT '成功UV(GroupPayOrderConfirm 且 paymentCallBack=Y)',
  17. etl_time TIMESTAMP COMMENT 'ETL 处理时间'
  18. ) COMMENT '拼团漏斗-昨日(每日增量;聚合UV非路径)'
  19. PARTITIONED BY (dt STRING)
  20. STORED AS ORC;
  21. -- ② 近7/30天(覆盖最新,非分区单行)
  22. CREATE TABLE IF NOT EXISTS ads.ads_trd_group_funnel_rolling (
  23. dt STRING COMMENT 'as-of 快照日 yyyyMMdd',
  24. uv_start_7d BIGINT COMMENT '近7天 启动UV',
  25. uv_show_7d BIGINT COMMENT '近7天 曝光UV',
  26. uv_detail_7d BIGINT COMMENT '近7天 拼团详情UV',
  27. uv_order_7d BIGINT COMMENT '近7天 下单UV',
  28. uv_paid_7d BIGINT COMMENT '近7天 成功UV',
  29. uv_start_30d BIGINT COMMENT '近30天 启动UV',
  30. uv_show_30d BIGINT COMMENT '近30天 曝光UV',
  31. uv_detail_30d BIGINT COMMENT '近30天 拼团详情UV',
  32. uv_order_30d BIGINT COMMENT '近30天 下单UV',
  33. uv_paid_30d BIGINT COMMENT '近30天 成功UV',
  34. etl_time TIMESTAMP COMMENT 'ETL 处理时间'
  35. ) COMMENT '拼团漏斗-近7/30天(每日覆盖最新1行;聚合UV非路径)'
  36. STORED AS ORC;