Skip to content

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

repair bug

parent da1246f6
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 7 deletions
eda/feededa/src/main/scala/com/gmei/strategy_other.scala
View file @ d1599f00
...@@ -102,7 +102,7 @@ object strategy_other { ...@@ -102,7 +102,7 @@ object strategy_other {
""".stripMargin """.stripMargin
) )
//device_id尾号1点击日记本用户数 /* //device_id尾号1点击日记本用户数
val clk_diary_device = sc.sql( val clk_diary_device = sc.sql(
s""" s"""
|select '${param.date}' as stat_date, count(distinct(device_id)) as clk_diary_device |select '${param.date}' as stat_date, count(distinct(device_id)) as clk_diary_device
...@@ -158,18 +158,18 @@ object strategy_other { ...@@ -158,18 +158,18 @@ object strategy_other {
|select '${param.date}' as stat_date,count(distinct(device_id)) as device_all_cover |select '${param.date}' as stat_date,count(distinct(device_id)) as device_all_cover
|from merge_queue_table |from merge_queue_table
""".stripMargin """.stripMargin
) )*/
val result = clk_active_1.join(imp_active_1,"stat_date") val result = clk_active_1.join(imp_active_1,"stat_date")
.join(clk_active_all,"stat_date") //.join(clk_active_all,"stat_date")
.join(imp_active_all,"stat_date") //.join(imp_active_all,"stat_date")
.join(clk_diary_device,"stat_date") //.join(clk_diary_device,"stat_date")
.join(clk_diary_device_cover,"stat_date") //.join(clk_diary_device_cover,"stat_date")
result.show() result.show()
GmeiConfig.writeToJDBCTable(result, "strategy_other", SaveMode.Append) //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