Skip to content

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

repair bug

parent 429849e2
Hide whitespace changes
Inline Side-by-side
Showing with 10 additions and 7 deletions
eda/feededa/src/main/scala/com/gmei/strategy_other.scala
View file @ b92fde2e
......@@ -77,7 +77,7 @@ object strategy_other {
//device_id尾号1有点击用户日记本点击数
val clk_active_1 = sc.sql(
s"""
|select '${param.date}' as stat_date, count(cid_id) as clk_active_1
|select '${param.date}' as stat_date, count(jd.cid_id) as clk_active_1
|from data_feed_click jd inner join device_id_old
|on jd.device_id = device_id_old.device_id
|where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
......@@ -91,7 +91,7 @@ object strategy_other {
//device_id尾号1有点击用户日记本曝光数
val imp_active_1 = sc.sql(
s"""
|select '${param.date}' as stat_date, count(cid_id) as imp_active_1
|select '${param.date}' as stat_date, count(je.cid_id) as imp_active_1
|from data_feed_exposure je inner join device_id_old
|on je.device_id = device_id_old.device_id
|where je.cid_type = 'diary'
......@@ -105,7 +105,7 @@ object strategy_other {
//device_id尾号1点击日记本用户数
val clk_diary_device = sc.sql(
s"""
|select '${param.date}' as stat_date, count(distinct(device_id)) as clk_diary_device
|select '${param.date}' as stat_date, count(distinct(jd.device_id)) as clk_diary_device
|from data_feed_click jd inner join device_id_old
|on jd.device_id = device_id_old.device_id
|where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
......@@ -117,9 +117,9 @@ object strategy_other {
)
//所有有点击用户日记本点击数
/* val clk_active_all = sc.sql(
val clk_active_all = sc.sql(
s"""
|select '${param.date}' as stat_date, count(cid_id) as clk_active_all
|select '${param.date}' as stat_date, count(jd.cid_id) as clk_active_all
|from data_feed_click jd inner join device_id_old
|on jd.device_id = device_id_old.device_id
|where (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
......@@ -132,7 +132,7 @@ object strategy_other {
//所有有点击用户日记本曝光数
val imp_active_all = sc.sql(
s"""
|select '${param.date}' as stat_date, count(cid_id) as imp_active_all
|select '${param.date}' as stat_date, count(je.cid_id) as imp_active_all
|from data_feed_exposure je inner join device_id_old
|on je.device_id = device_id_old.device_id
|where je.cid_type = 'diary'
......@@ -163,8 +163,11 @@ object strategy_other {
val result = clk_active_1.join(imp_active_1,"stat_date")
.join(clk_active_all,"stat_date")
.join(imp_active_all,"stat_date")
.join(clk_diary_device,"stat_date")
//.join(clk_diary_device_cover,"stat_date")
.join(clk_diary_device_cover,"stat_date")
.join(device_all_cover,"stat_date")
result.show()
//GmeiConfig.writeToJDBCTable(result, "strategy_other", SaveMode.Append)
......
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