From fd7275ec5b9a2cf7983860e4ac56e431485f5e31 Mon Sep 17 00:00:00 2001
From: mengdongxing <mengdongxing@reyun.com>
Date: Thu, 16 Mar 2017 07:38:57 +0000
Subject: [PATCH] Update tkdm_output_user_cluster_app_day.sql

---
 tkdm_output_user_cluster_app_day.sql | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/tkdm_output_user_cluster_app_day.sql b/tkdm_output_user_cluster_app_day.sql
index 1eab3c1..f80e7c8 100644
--- a/tkdm_output_user_cluster_app_day.sql
+++ b/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 
--
libgit2 0.27.1