Commit 26adcdf9 authored by 王志伟's avatar 王志伟

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

parent 246e3a1c
...@@ -116,6 +116,24 @@ object temp_analysis { ...@@ -116,6 +116,24 @@ object temp_analysis {
) )
final_id.createOrReplaceTempView("final_id") final_id.createOrReplaceTempView("final_id")
val diary_clk_all = sc.sql(
s"""
|select ov.partition_date,count(ov.cl_id) as clk_num,count(distinct(ov.cl_id)),count(ov.cl_id)/count(distinct(ov.cl_id))
|from online.tl_hdfs_maidian_view ov left join final_id
|on ov.cl_id = final_id.device_id
|where ov.action = "page_view"
|and params['page_name']="diary_detail"
|and ov.cl_id != "NULL"
|and ov.partition_date >='20181201'
|and final_id.device_id is null
|group by ov.partition_date
|order by ov.partition_date
""".stripMargin
)
diary_clk_all.show(80)
//日记本点击 //日记本点击
val referrer=List("about_me_message_list","all_case_service_comment","all_cases","diary_detail","diary_list" val referrer=List("about_me_message_list","all_case_service_comment","all_cases","diary_detail","diary_list"
,"diary_listof_related_service","answer_detail","community_home","conversation_detail","create_diary_title","diary_listof_related_service", ,"diary_listof_related_service","answer_detail","community_home","conversation_detail","create_diary_title","diary_listof_related_service",
...@@ -144,6 +162,8 @@ object temp_analysis { ...@@ -144,6 +162,8 @@ object temp_analysis {
} }
//5.登录人数 //5.登录人数
val log_device_temp = sc.sql( val log_device_temp = sc.sql(
s""" s"""
......
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