poyee-data-warehouse/manual/ddl/ads/trd/ads_trd_group_funnel_create.sql

-- 作者：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;