Commit ec672806 by WangJinfeng

add ods_dmp_user_info_daily_mapping

parent c40d552d
......@@ -111,7 +111,7 @@ class InstallListDailyV2 extends CommonSparkJob with Serializable {
| FROM
| (SELECT LOWER(device_id) device_id,device_type,platform,country,install_list,ext_data,update_date,business
| FROM dwh.dmp_install_list d LEFT SEMI JOIN active_dev a ON LOWER(d.device_id) = a.device_id
| WHERE dt = '@date' AND business NOT IN ('ga','other','14days','day','adn_request_unmatch','dsp_req_unmatch')
| WHERE dt = '@date' AND business NOT IN ('ga','other','14days','day')
| UNION
| SELECT LOWER(device_id) device_id,device_type,platform,country,install_list,ext_data,update_date,business
| FROM dwh.dmp_install_list d LEFT SEMI JOIN active_dev a ON LOWER(d.device_id) = a.device_id
......
......@@ -22,7 +22,7 @@ class DeviceIDMappingLower extends CommonSparkJob with Serializable {
try {
val sc = spark.sparkContext
val updateDate = MobvistaConstant.sdf1.format(MobvistaConstant.sdf2.parse(date))
val lastDate = DateUtil.getDayByString(date, "yyyy-MM-dd", -1)
val lastDate = DateUtil.getDayByString(date, "yyyyMMdd", -1)
val lastUpdateDate = DateUtil.getDayByString(updateDate, "yyyy-MM-dd", -1)
val sql =
......
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