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