Skip to content

F
ffm-baseline
Commit 5468c75a authored by 王志伟's avatar 王志伟
Browse files
Options

check warnnig

parent 30cd9ddd
Show whitespace changes
Inline Side-by-side
Showing with 6 additions and 6 deletions
eda/feededa/src/main/scala/com/gmei/strategy_clk_imp_oldUser.scala
View file @ 5468c75a
...@@ -53,7 +53,7 @@ object strategy_clk_imp_oldUser { ...@@ -53,7 +53,7 @@ object strategy_clk_imp_oldUser {
val partition_date = stat_date.replace("-","") val partition_date = stat_date.replace("-","")
val decive_id_oldUser = sc.sql( val decive_id_oldUser = sc.sql(
s""" s"""
|select distinct(device_id) as decive_id_oldUser |select distinct(device_id) as decive_id
|from online.ml_device_day_active_status |from online.ml_device_day_active_status
|where active_type = '4' |where active_type = '4'
|and partition_date ='${partition_date}' |and partition_date ='${partition_date}'
...@@ -64,7 +64,7 @@ object strategy_clk_imp_oldUser { ...@@ -64,7 +64,7 @@ object strategy_clk_imp_oldUser {
val decive_id_newUser = sc.sql( val decive_id_newUser = sc.sql(
s""" s"""
|select distinct(device_id) as decive_id_newUser |select distinct(device_id) as decive_id
|from online.ml_device_day_active_status |from online.ml_device_day_active_status
|where (active_type = '1' or active_type = '2' or active_type = '3') |where (active_type = '1' or active_type = '2' or active_type = '3')
|and partition_date ='${partition_date}' |and partition_date ='${partition_date}'
...@@ -79,7 +79,7 @@ object strategy_clk_imp_oldUser { ...@@ -79,7 +79,7 @@ object strategy_clk_imp_oldUser {
s""" s"""
|select '${stat_date}' as stat_date, count(cid_id) as get_clk_count_old |select '${stat_date}' as stat_date, count(cid_id) as get_clk_count_old
|from data_feed_click jd inner join device_id_old |from data_feed_click jd inner join device_id_old
|on jd.device_id = device_id_old.decive_id_oldUser |on jd.device_id = device_id_old.decive_id
|where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video') |where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
|and jd.device_id regexp'${strategy}' |and jd.device_id regexp'${strategy}'
|and jd.device_id not in (select device_id from bl_device_list) |and jd.device_id not in (select device_id from bl_device_list)
...@@ -92,7 +92,7 @@ object strategy_clk_imp_oldUser { ...@@ -92,7 +92,7 @@ object strategy_clk_imp_oldUser {
s""" s"""
|select '${stat_date}' as stat_date, count(cid_id) as get_imp_count_old |select '${stat_date}' as stat_date, count(cid_id) as get_imp_count_old
|from data_feed_exposure je inner join device_id_old |from data_feed_exposure je inner join device_id_old
|on je.device_id = device_id_old.decive_id_oldUser |on je.device_id = device_id_old.decive_id
|where je.cid_type = 'diary' |where je.cid_type = 'diary'
|and je.device_id regexp'${strategy}' |and je.device_id regexp'${strategy}'
|and je.device_id not in (select device_id from bl_device_list) |and je.device_id not in (select device_id from bl_device_list)
...@@ -106,7 +106,7 @@ object strategy_clk_imp_oldUser { ...@@ -106,7 +106,7 @@ object strategy_clk_imp_oldUser {
s""" s"""
|select '${stat_date}' as stat_date, count(cid_id) as get_clk_count_newUser |select '${stat_date}' as stat_date, count(cid_id) as get_clk_count_newUser
|from data_feed_click jd inner join device_id_newUser |from data_feed_click jd inner join device_id_newUser
|on jd.device_id = device_id_newUser.decive_id_newUser |on jd.device_id = device_id_newUser.decive_id
|where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video') |where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
|and jd.device_id regexp'${strategy}' |and jd.device_id regexp'${strategy}'
|and jd.device_id not in (select device_id from bl_device_list) |and jd.device_id not in (select device_id from bl_device_list)
...@@ -119,7 +119,7 @@ object strategy_clk_imp_oldUser { ...@@ -119,7 +119,7 @@ object strategy_clk_imp_oldUser {
s""" s"""
|select '${stat_date}' as stat_date, count(cid_id) as get_imp_count_newUser |select '${stat_date}' as stat_date, count(cid_id) as get_imp_count_newUser
|from data_feed_exposure je inner join device_id_newUser |from data_feed_exposure je inner join device_id_newUser
|on je.device_id = device_id_newUser.decive_id_newUser |on je.device_id = device_id_newUser.decive_id
|where je.cid_type = 'diary' |where je.cid_type = 'diary'
|and je.device_id regexp'${strategy}' |and je.device_id regexp'${strategy}'
|and je.device_id not in (select device_id from bl_device_list) |and je.device_id not in (select device_id from bl_device_list)
......
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