Commit 5d6c8577 authored by 高雅喆's avatar 高雅喆

add device_search_tag

parent a6cbd3c8
...@@ -548,20 +548,16 @@ object GetDevicePortrait { ...@@ -548,20 +548,16 @@ object GetDevicePortrait {
val device_search_tag = sc.sql( val device_search_tag = sc.sql(
s""" s"""
|select a.cl_id as device_id,COALESCE(a.params['diary_id'], a.params['business_id'], 0) as cid_id,split(c.level1_ids,',')[0] as level1_id |select
|from online.tl_hdfs_maidian_view as a | a.cl_id as device_id,a.partition_date as stat_date,
|left join | COALESCE(a.params['diary_id'], a.params['business_id'], 0) as cid_id,
| (select cl_id as device_id,max(partition_date) as stat_date | split(b.level1_ids,',')[0] as level1_id
| from online.tl_hdfs_maidian_view |from online.tl_hdfs_maidian_view a
| where action = 'on_click_diary_card' |left join diary_feat b
| and (params['page_name']='search_result_diary' or params['page_name']='search_result_more') |on COALESCE(a.params['diary_id'], a.params['business_id'], 0) = b.diary_id
| and partition_date > '20180601' group by cl_id) b |where
|on a.cl_id = b.device_id and a.partition_date=b.stat_date | partition_date = '20181224'
|left join diary_feat c | and (action = 'on_click_diary_card' or (action="full_stack_click_video_card_full_screen_play" and params["card_type"]="diary")))
|on COALESCE(a.params['diary_id'], a.params['business_id'], 0) = c.diary_id
|where a.partition_date > '20180601'
|and COALESCE(a.params['diary_id'], a.params['business_id'], 0) != 0
|and c.level1_ids != ""
""".stripMargin """.stripMargin
) )
device_search_tag.show() device_search_tag.show()
......
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