Commit 27a2fc41 authored by 王志伟's avatar 王志伟

统计新指标,device_clk_imp_reason

parent 36216c6f
...@@ -767,12 +767,13 @@ object find_reason { ...@@ -767,12 +767,13 @@ object find_reason {
|and agency_id.device_id is null |and agency_id.device_id is null
""".stripMargin """.stripMargin
) )
all_clk.show()
all_clk.createOrReplaceTempView("all_clk_diary_card") all_clk.createOrReplaceTempView("all_clk_diary_card")
//1.当天老用户中的点击用户数 //1.当天老用户中的点击用户数
val old_clk_count = sc.sql( val old_clk_count = sc.sql(
s""" s"""
|select stat_date,count(ov.device_id) as old_clk_count |select stat_date,count(oc.device_id) as old_clk_count
|from all_clk_diary_card oc left join device_id_old |from all_clk_diary_card oc left join device_id_old
|on oc.device_id = device_id_old.device_id |on oc.device_id = device_id_old.device_id
|where device_id_old.device_id is not null |where device_id_old.device_id is not null
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment