push codes

pm/daily_push/etl/daily_push.sql

@@ -35,10 +35,10 @@ SELECT  t1.partition_date as day_id
        ,sum(NVL(t2.sign_push_open_pv,0)) as sign_push_open_pv                                                                             --签到push拉起人次
        ,count(distinct case when sign_push_open_2_pv is not null and sign_push_open_2_pv>0 then t5.cl_id end) as sign_push_open_2_uv  --签到push拉起有2跳设备数
        ,sum(NVL(t5.sign_push_open_2_pv,0)) as sign_push_open_2_pv
-       ,count(distinct case when t2.ctr_push_open_pv+t2.non_ctr_push_open_pv>0 then t2.cl_id end) as personal_push_open_uv        --个性化push拉起设备数
-       ,sum(NVL(t2.ctr_push_open_pv+t2.non_ctr_push_open_pv,0)) as personal_push_open_pv                                                                             --个性化push拉起人次
-       ,count(distinct case when t5.ctr_push_open_2_pv+t5.non_ctr_push_open_2_pv>0 then t5.cl_id end) as personal_push_open_2_uv        --个性化push拉起设备数
-       ,sum(NVL(t5.ctr_push_open_2_pv+t5.non_ctr_push_open_2_pv,0)) as personal_push_open_2_pv                                                                       --个性化push拉起有2跳人次
+       ,count(distinct case when t2.ctr_push_open_pv+t2.non_ctr_push_open_pv+t2.will_push_open_pv>0 then t2.cl_id end) as personal_push_open_uv        --个性化push拉起设备数
+       ,sum(NVL(t2.ctr_push_open_pv+t2.non_ctr_push_open_pv+t2.will_push_open_pv,0)) as personal_push_open_pv                                                                             --个性化push拉起人次
+       ,count(distinct case when t5.ctr_push_open_2_pv+t5.non_ctr_push_open_2_pv+t5.will_push_open_2_pv>0 then t5.cl_id end) as personal_push_open_2_uv        --个性化push拉起设备数
+       ,sum(NVL(t5.ctr_push_open_2_pv+t5.non_ctr_push_open_2_pv+t5.will_push_open_2_pv,0)) as personal_push_open_2_pv                                                                       --个性化push拉起有2跳人次
        ,count(distinct case when ctr_push_open_pv is not null and ctr_push_open_pv>0 then t2.cl_id end) as ctr_push_open_uv        --签到push拉起设备数
        ,sum(NVL(t2.ctr_push_open_pv,0)) as ctr_push_open_pv                                                                             --签到push拉起人次
        ,count(distinct case when ctr_push_open_2_pv is not null and ctr_push_open_2_pv>0 then t5.cl_id end) as ctr_push_open_2_uv  --签到push拉起有2跳设备数

pm/daily_recommend_strategy/etl/daily_recommend_strategy.sql

@@ -8,8 +8,6 @@ SET mapred.reduce.tasks=20;
 SET role admin;
 
 
-ADD JAR hdfs:///user/hive/share/lib/udf/hive-udf-1.0-SNAPSHOT.jar;
-CREATE TEMPORARY FUNCTION convup AS 'com.gmei.hive.common.udf.UDFConvUpgrade';
 
 INSERT OVERWRITE TABLE pm.tl_pm_recommend_strategy_d PARTITION (PARTITION_DAY = ${partition_day})
 SELECT