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

esmm pre data on activate user and filter > 10days

parent fa68f71c
...@@ -241,13 +241,13 @@ object EsmmPredData { ...@@ -241,13 +241,13 @@ 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(1) val yesteday_have_seq = GmeiConfig.getMinusNDate(10)
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}'
""".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