Commit 62841705 authored by 王志伟's avatar 王志伟

change sql

parent a3b5b964
...@@ -54,12 +54,11 @@ object testt { ...@@ -54,12 +54,11 @@ object testt {
val get_data_dura = sc.sql( val get_data_dura = sc.sql(
s""" s"""
|select count(cid_id) as get_clk_count_newUser |select count(cid_id) as get_clk_count_newUser
|from data_feed_click jd inner join device_id_newUser |from data_feed_click
|on jd.device_id = device_id_newUser.decive_id |where (cid_type = 'diary' or cid_type = 'diary_video')
|where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video') |and device_id regexp'${strategy}'
|and jd.device_id regexp'${strategy}' |and device_id not in (select device_id from bl_device_list)
|and jd.device_id not in (select device_id from bl_device_list) |and device_id not in (select device_id from blacklist)
|and jd.device_id not in (select device_id from blacklist)
""".stripMargin """.stripMargin
) )
get_data_dura.show() get_data_dura.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