Skip to content

F
ffm-baseline
Commit 4d4a046b authored by 张彦钊's avatar 张彦钊
Browse files
Options

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

add print
parents 4426d8db 932395b5
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
eda/feededa/src/main/scala/com/gmei/EsmmData.scala
View file @ 4d4a046b
...@@ -186,7 +186,7 @@ object EsmmData { ...@@ -186,7 +186,7 @@ object EsmmData {
) )
// union_data_scity_id.createOrReplaceTempView("union_data_scity_id") // union_data_scity_id.createOrReplaceTempView("union_data_scity_id")
union_data_scity_id.show() union_data_scity_id.show()
GmeiConfig.writeToJDBCTable(union_data_scity_id, table="esmm_data",SaveMode.Overwrite) GmeiConfig.writeToJDBCTable("jdbc:mysql://10.66.157.22:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",union_data_scity_id, table="esmm_train_data",SaveMode.Overwrite)
...@@ -241,7 +241,7 @@ object EsmmPredData { ...@@ -241,7 +241,7 @@ object EsmmPredData {
ti.tidbMapTable(dbName = "jerry_prod",tableName = "data_feed_exposure") ti.tidbMapTable(dbName = "jerry_prod",tableName = "data_feed_exposure")
val yesteday_have_seq = GmeiConfig.getMinusNDate(10) val yesteday_have_seq = GmeiConfig.getMinusNDate(5)
val activate_data = sc.sql( val activate_data = sc.sql(
s""" s"""
|select a.device_id,a.city_id as ucity_id,explode(split(a.search_queue, ',')) as cid_id |select a.device_id,a.city_id as ucity_id,explode(split(a.search_queue, ',')) as cid_id
......
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