Commit 03189e98 by WangJinfeng

update rtdmp set default device_type = unknown

parent bb144cdc
...@@ -79,7 +79,8 @@ class RTDmpMergeCK extends CommonSparkJob with Serializable { ...@@ -79,7 +79,8 @@ class RTDmpMergeCK extends CommonSparkJob with Serializable {
val sql = val sql =
""" """
|SELECT devid, process(audience_map) audience_id, device_type |SELECT devid, process(audience_map) audience_id,
| CASE WHEN device_type IS NOT NULL AND device_type != '' THEN device_type ELSE 'unknown' END AS device_type
| FROM dwh.audience_merge | FROM dwh.audience_merge
| WHERE dt = '@dt' | WHERE dt = '@dt'
|""".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