[log]2023-09-27 插入分区表partition(d

2023-09-26  本文已影响0人  麒麟楚庄王

采用动态分区

insert overwrite table lao.lk_opr_ar_model_monitor_xbsp_auditcode_log_pt partition(dt)

    Select tmp.riskcode,count(1) cnt,a.dt

    FROM (select dt,user_id,`value`

    from xuan.fact_user_model_variable

    where tag = 'ar_xb_auditreasonid_dedup'

    and dt = CURRENT_DATE()

    ) a   

    lateral view explode(split(`value`,',')) tmp as riskcode

    group by a.dt,tmp.riskcode;

上一篇 下一篇

猜你喜欢

热点阅读