Skip to content

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

chang

parent fb8247dd
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
eda/feededa/src/main/scala/com/gmei/strategy_clk_imp_oldUser.scala
View file @ 585d39c9
...@@ -78,7 +78,7 @@ object strategy_clk_imp_oldUser { ...@@ -78,7 +78,7 @@ object strategy_clk_imp_oldUser {
val clk_count_oldUser = sc.sql( val clk_count_oldUser = sc.sql(
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 left join device_id_old |from data_feed_click jd inner join device_id_old
|on jd.device_id = device_id_old.decive_id |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}'
...@@ -92,7 +92,7 @@ object strategy_clk_imp_oldUser { ...@@ -92,7 +92,7 @@ object strategy_clk_imp_oldUser {
val imp_count_oldUser = sc.sql( val imp_count_oldUser = sc.sql(
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 left join device_id_old |from data_feed_exposure je inner join device_id_old
|on je.device_id = device_id_old.decive_id |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}'
...@@ -107,7 +107,7 @@ object strategy_clk_imp_oldUser { ...@@ -107,7 +107,7 @@ object strategy_clk_imp_oldUser {
val clk_count_newUser = sc.sql( val clk_count_newUser = sc.sql(
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 left join device_id_newUser |from data_feed_click jd inner join device_id_newUser
|on jd.device_id = device_id_newUser.decive_id |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}'
...@@ -121,7 +121,7 @@ object strategy_clk_imp_oldUser { ...@@ -121,7 +121,7 @@ object strategy_clk_imp_oldUser {
val imp_count_newUser = sc.sql( val imp_count_newUser = sc.sql(
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 left join device_id_newUser |from data_feed_exposure je inner join device_id_newUser
|on je.device_id = device_id_newUser.decive_id |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}'
......
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