跑波动原因数据

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

@@ -119,16 +119,14 @@ object temp_analysis {
 
       val diary_clk_new = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date,a.device_id,count(a.diary_id)
-           |(select ov.partition_date,ov.cl_id as device_id,ov.params['diary_id'] as diary_id
+           |select ov.partition_date,ov.cl_id as device_id,ov.params['diary_id'] as diary_id
            |from online.tl_hdfs_maidian_view ov inner join device_id_new
            |on ov.cl_id = device_id_new.device_id
            |where ov.action = 'on_click_diary_card'
            |and ov.params['tab_name'] = '精选'
            |and ov.params['page_name'] = 'home'
            |and ov.partition_date='${partition_date}'
-           |and agency_id.device_id is  null) a
-           |group by a.device_id
+           |and agency_id.device_id is  null
        """.stripMargin
       )
       diary_clk_new.show(80)