Update tkdm_output_user_cluster_app_day.sql

tkdm_output_user_cluster_app_day.sql

@@ -4,15 +4,16 @@ set Mapred.min.split.size.per.rack=256000000
 set hive.input.format=org.apache.hadoop.hive.ql.io.CombineHiveInputFormat
 set hive.groupby.skewindata=true;
 
-insert overwrite table tkdm.tkdm_output_user_cluster_app_day partition(ds='2017-02-25')
+insert overwrite table tkdm.tkdm_output_user_cluster_app_day partition(ds='$ds')
 
-select '2017-02-25' as dt,
+select '$ds' as dt,
        appid,
        category_id,
        isgame,
-       count(1)  as num_user
+       count(if(cid=-1,1,null))  as num_user_def,
+       count(if(cid!=-1,1,null))  as num_user_cam
 from tkdm.tkdm_data_active_detial_day
-where ds='2017-02-25'
+where ds='$ds'
 group by appid,category_id,isgame
 cluster by appid,category_id,isgame
 
@@ -24,7 +25,8 @@ dt string,
 appid int,
 category_id int,
 isgame int,
-num_user int
+num_user_def bigint,
+num_user_cam bigint
 )
 PARTITIONED BY (ds string)
 ROW FORMAT DELIMITED