Commit bd42e51d authored by 高雅喆's avatar 高雅喆

Merge branch 'master' of git.wanmeizhensuo.com:ML/ffm-baseline

add uid duration
parents f7324e6a e0cf3674
...@@ -201,7 +201,7 @@ object Recommendation_strategy_all { ...@@ -201,7 +201,7 @@ object Recommendation_strategy_all {
.join(device_num_hit,"stat_date") .join(device_num_hit,"stat_date")
result1.show() result1.show()
GmeiConfig.writeToJDBCTable(result1, "Recommendation_strategy_temp", SaveMode.Append) // GmeiConfig.writeToJDBCTable(result1, "Recommendation_strategy_temp", SaveMode.Append)
//device_id尾号1有点击用户日记本点击数 //device_id尾号1有点击用户日记本点击数
...@@ -298,7 +298,7 @@ object Recommendation_strategy_all { ...@@ -298,7 +298,7 @@ object Recommendation_strategy_all {
.join(device_all_cover,"stat_date") .join(device_all_cover,"stat_date")
result2.show() result2.show()
GmeiConfig.writeToJDBCTable(result2, "strategy_other", SaveMode.Append) // GmeiConfig.writeToJDBCTable(result2, "strategy_other", SaveMode.Append)
//统计新用户点击率 //统计新用户点击率
...@@ -371,7 +371,7 @@ object Recommendation_strategy_all { ...@@ -371,7 +371,7 @@ object Recommendation_strategy_all {
.join(imp_count_newUser_all,"stat_date") .join(imp_count_newUser_all,"stat_date")
result3.show() result3.show()
GmeiConfig.writeToJDBCTable(result3, "Recommendation_strategy_newUser", SaveMode.Append) // GmeiConfig.writeToJDBCTable(result3, "Recommendation_strategy_newUser", SaveMode.Append)
} }
......
...@@ -50,8 +50,8 @@ object testt { ...@@ -50,8 +50,8 @@ object testt {
ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist") ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure") ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
// val stat_date = GmeiConfig.getMinusNDate(1) val stat_date = GmeiConfig.getMinusNDate(1)
val stat_date=param.date // val stat_date=param.date
val partition_date = stat_date.replace("-","") val partition_date = stat_date.replace("-","")
//机构id //机构id
val blacklist = sc.sql( val blacklist = sc.sql(
......
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