Commit 5d5e95e5 by fan.jiang

add other business data to dwh.ods_dmp_user_info_daily

parent 8c7555e2
...@@ -113,7 +113,7 @@ class OdsDmpUserInfoDailyV2 extends CommonSparkJob with Serializable { ...@@ -113,7 +113,7 @@ class OdsDmpUserInfoDailyV2 extends CommonSparkJob with Serializable {
|union all |union all
|select lower(device_id) device_id,device_type,platform,country |select lower(device_id) device_id,device_type,platform,country
|from dwh.ods_dmp_user_info |from dwh.ods_dmp_user_info
|where dt='$yesBef2Str' and last_req_day='$yesBef2Part' and business in ('ga') ) X |where dt='$yesBef2Str' and last_req_day='$yesBef2Part' and business in ('ga','other') ) X
|group by X.device_id |group by X.device_id
""".stripMargin """.stripMargin
val device_daily_df = spark.sql(hql).persist(StorageLevel.MEMORY_AND_DISK_SER) val device_daily_df = spark.sql(hql).persist(StorageLevel.MEMORY_AND_DISK_SER)
......
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