Commit 4cf40b7a authored by 王志伟's avatar 王志伟

加快取值速度

parent 06679a72
...@@ -124,7 +124,7 @@ object Recommendation_strategy_all { ...@@ -124,7 +124,7 @@ object Recommendation_strategy_all {
""".stripMargin """.stripMargin
) )
//获取策略命中用户device_id /*//获取策略命中用户device_id
val device_id_cover = sc.sql( val device_id_cover = sc.sql(
s""" s"""
|select distinct(device_id) as device_id |select distinct(device_id) as device_id
...@@ -157,15 +157,15 @@ object Recommendation_strategy_all { ...@@ -157,15 +157,15 @@ object Recommendation_strategy_all {
|and je.stat_date ='${param.date}' |and je.stat_date ='${param.date}'
""".stripMargin """.stripMargin
) )
*/
val result = clk_count_oldUser_Contrast.join(imp_count_oldUser_Contrast,"stat_date") val result = clk_count_oldUser_Contrast.join(imp_count_oldUser_Contrast,"stat_date")
.join(clk_count_oldUser_all,"stat_date") .join(clk_count_oldUser_all,"stat_date")
.join(imp_count_oldUser_all,"stat_date") .join(imp_count_oldUser_all,"stat_date")
.join(clk_count_oldUser_Cover,"stat_date") /*.join(clk_count_oldUser_Cover,"stat_date")
.join(imp_count_oldUser_Cover,"stat_date") .join(imp_count_oldUser_Cover,"stat_date")*/
result.show() result.show()
GmeiConfig.writeToJDBCTable(result, "Recommendation_strategy_temp", SaveMode.Append) GmeiConfig.writeToJDBCTable(result, "Recommendation_strategy_temp", 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