Commit cd1ac97b authored by 王志伟's avatar 王志伟
parents 489c5c51 6bafdeb6
...@@ -241,13 +241,14 @@ object EsmmPredData { ...@@ -241,13 +241,14 @@ 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(5) val yesteday_have_seq = GmeiConfig.getMinusNDate(1)
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
|from merge_queue_table a |from merge_queue_table a
|left join data_feed_exposure b on a.device_id=b.device_id and a.city_id=b.city_id |left join data_feed_exposure b on a.device_id=b.device_id and a.city_id=b.city_id
|where b.stat_date >'${yesteday_have_seq}' |where b.stat_date ='${yesteday_have_seq}'
|and b.device_id is not null
""".stripMargin """.stripMargin
) )
......
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