Skip to content

F
ffm-baseline
Commit 932395b5 authored by 高雅喆's avatar 高雅喆
Browse files
Options

esmm pre data on activate user and filter > 5days and write to jerry_test

parent f896ed52
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 @ 932395b5
...@@ -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