统计日记本点击的各个来源数量

eda/feededa/src/main/scala/com/gmei/temp_analysis.scala

@@ -76,23 +76,23 @@ object temp_analysis {
       agency_id.createOrReplaceTempView("agency_id")
 
 
-      //每日新用户
-      val device_id_newUser = sc.sql(
-        s"""
-           |select distinct(device_id) as device_id
-           |from online.ml_device_day_active_status
-           |where active_type != '4'
-           |and first_channel_source_type not in ('yqxiu1','yqxiu2','yqxiu3','yqxiu4','yqxiu5','mxyc1','mxyc2','mxyc3'
-           |        ,'wanpu','jinshan','jx','maimai','zhuoyi','huatian','suopingjingling','mocha','mizhe','meika','lamabang'
-           |        ,'js-az1','js-az2','js-az3','js-az4','js-az5','jfq-az1','jfq-az2','jfq-az3','jfq-az4','jfq-az5','toufang1'
-           |        ,'toufang2','toufang3','toufang4','toufang5','toufang6','TF-toufang1','TF-toufang2','TF-toufang3','TF-toufang4'
-           |        ,'TF-toufang5','tf-toufang1','tf-toufang2','tf-toufang3','tf-toufang4','tf-toufang5','benzhan','promotion_aso100'
-           |        ,'promotion_qianka','promotion_xiaoyu','promotion_dianru','promotion_malioaso','promotion_malioaso-shequ'
-           |        ,'promotion_shike','promotion_julang_jl03')
-           |and partition_date ='${partition_date}'
-         """.stripMargin
-      )
-      device_id_newUser.createOrReplaceTempView("device_id_new")
+//      //每日新用户
+//      val device_id_newUser = sc.sql(
+//        s"""
+//           |select distinct(device_id) as device_id
+//           |from online.ml_device_day_active_status
+//           |where active_type != '4'
+//           |and first_channel_source_type not in ('yqxiu1','yqxiu2','yqxiu3','yqxiu4','yqxiu5','mxyc1','mxyc2','mxyc3'
+//           |        ,'wanpu','jinshan','jx','maimai','zhuoyi','huatian','suopingjingling','mocha','mizhe','meika','lamabang'
+//           |        ,'js-az1','js-az2','js-az3','js-az4','js-az5','jfq-az1','jfq-az2','jfq-az3','jfq-az4','jfq-az5','toufang1'
+//           |        ,'toufang2','toufang3','toufang4','toufang5','toufang6','TF-toufang1','TF-toufang2','TF-toufang3','TF-toufang4'
+//           |        ,'TF-toufang5','tf-toufang1','tf-toufang2','tf-toufang3','tf-toufang4','tf-toufang5','benzhan','promotion_aso100'
+//           |        ,'promotion_qianka','promotion_xiaoyu','promotion_dianru','promotion_malioaso','promotion_malioaso-shequ'
+//           |        ,'promotion_shike','promotion_julang_jl03')
+//           |and partition_date ='${partition_date}'
+//         """.stripMargin
+//      )
+//      device_id_newUser.createOrReplaceTempView("device_id_new")
 
       val blacklist_id = sc.sql(
         s"""
@@ -108,9 +108,6 @@ object temp_analysis {
            |from agency_id
            |UNION ALL
            |select device_id
-           |from device_id_new
-           |UNION ALL
-           |select device_id
            |from blacklist_id
          """.stripMargin
       )