push codes

pm/meigou_detail_page/report/meigou_detail_page_dispense_pv.sql

+SET mapreduce.job.queuename=data;
+
 --美购详情页的分发
 SELECT `日期`,`设备类型`,`活跃类型`,`渠道`
 		,`美购详情页浏览pv`
@@ -76,8 +78,8 @@ FROM
                 FROM ml.ml_d_ct_dv_devicespam_d
                 WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 		    )spam_pv
-		    on pv.cl_id=spam_pv.cl_id
-		    WHERE spam_pv.cl_id IS NULL
+		    on pv.cl_id=spam_pv.device_id
+		    WHERE spam_pv.device_id IS NULL
 
 			UNION ALL
 

pm/meigou_detail_page/report/meigou_detail_page_dispense_uv.sql

@@ -76,8 +76,8 @@ FROM
                 FROM ml.ml_d_ct_dv_devicespam_d
                 WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 		    )spam_pv
-		    on uv.cl_id=spam_pv.cl_id
-		    WHERE spam_pv.cl_id IS NULL
+		    on uv.cl_id=spam_pv.device_id
+		    WHERE spam_pv.device_id IS NULL
 
 			UNION ALL
 

pm/meigou_detail_page/report/meigou_detail_page_source_pv.sql

@@ -250,8 +250,8 @@ FROM
             FROM ml.ml_d_ct_dv_devicespam_d
             WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 	    )spam_pv
-	    on t1.cl_id=spam_pv.cl_id
-	    WHERE spam_pv.cl_id IS NULL
+	    on t1.cl_id=spam_pv.device_id
+	    WHERE spam_pv.device_id IS NULL
 	)t1
     LATERAL VIEW explode(t1.channel) t2 AS channel
     GROUP BY t1.partition_date,t1.device_type,t1.active_type,t2.channel
@@ -334,8 +334,8 @@ LEFT JOIN
             FROM ml.ml_d_ct_dv_devicespam_d
             WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 	    )spam_pv
-	    on t1.cl_id=spam_pv.cl_id
-	    WHERE spam_pv.cl_id IS NULL
+	    on t1.cl_id=spam_pv.device_id
+	    WHERE spam_pv.device_id IS NULL
 	)t1
     LATERAL VIEW explode(t1.channel) t2 AS channel
     GROUP BY t1.partition_date,t1.device_type,t1.active_type,t2.channel
@@ -486,8 +486,8 @@ LEFT JOIN
             FROM ml.ml_d_ct_dv_devicespam_d
             WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 	    )spam_pv
-	    on t1.cl_id=spam_pv.cl_id
-	    WHERE spam_pv.cl_id IS NULL
+	    on t1.cl_id=spam_pv.device_id
+	    WHERE spam_pv.device_id IS NULL
 	)t1
     LATERAL VIEW explode(t1.channel) t2 AS channel
     GROUP BY t1.partition_date,t1.device_type,t1.active_type,t2.channel

pm/meigou_detail_page/report/meigou_detail_page_source_uv.sql

@@ -244,8 +244,8 @@ FROM
             FROM ml.ml_d_ct_dv_devicespam_d
             WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 	    )spam_pv
-	    on t1.cl_id=spam_pv.cl_id
-	    WHERE spam_pv.cl_id IS NULL
+	    on t1.cl_id=spam_pv.device_id
+	    WHERE spam_pv.device_id IS NULL
 	)t1
     LATERAL VIEW explode(t1.channel) t2 AS channel
     GROUP BY t1.partition_date,t1.device_type,t1.active_type,t2.channel
@@ -328,8 +328,8 @@ LEFT JOIN
             FROM ml.ml_d_ct_dv_devicespam_d
             WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 	    )spam_pv
-	    on t1.cl_id=spam_pv.cl_id
-	    WHERE spam_pv.cl_id IS NULL
+	    on t1.cl_id=spam_pv.device_id
+	    WHERE spam_pv.device_id IS NULL
 	)t1
     LATERAL VIEW explode(t1.channel) t2 AS channel
     GROUP BY t1.partition_date,t1.device_type,t1.active_type,t2.channel
@@ -480,8 +480,8 @@ LEFT JOIN
             FROM ml.ml_d_ct_dv_devicespam_d
             WHERE partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
 	    )spam_pv
-	    on t1.cl_id=spam_pv.cl_id
-	    WHERE spam_pv.cl_id IS NULL
+	    on t1.cl_id=spam_pv.device_id
+	    WHERE spam_pv.device_id IS NULL
 	)t1
     LATERAL VIEW explode(t1.channel) t2 AS channel
     GROUP BY t1.partition_date,t1.device_type,t1.active_type,t2.channel