彦钊更改esmmData

3be5052f · 王志伟 · 40e29a95 · 3be5052f
Commit 3be5052f authored Jan 21, 2019 by 王志伟
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 3 deletions

EsmmData.scala eda/feededa/src/main/scala/com/gmei/EsmmData.scala +1 -3

No files found.
--- a/eda/feededa/src/main/scala/com/gmei/EsmmData.scala
+++ b/eda/feededa/src/main/scala/com/gmei/EsmmData.scala
@@ -332,9 +332,7 @@ object EsmmPredData {

      val native_data1 = sc.sql(
        s"""
-           |select device_id,city_id as ucity_id,
-           |explode(native_queue) as cid_id
-           |from native_data
+           |select device_id,city_id as ucity_id,explode(split(native_queue,',')) as cid_id from native_data
          """.stripMargin
      ).withColumn("label",lit(0))
      native_data1.createOrReplaceTempView("native_data1")