彦钊更改esmmData

eda/feededa/src/main/scala/com/gmei/EsmmData.scala

@@ -333,9 +333,9 @@ object EsmmPredData {
       val native_data1 = sc.sql(
         s"""
            |select device_id,city_id as ucity_id,
-           |explode(split(split(native_queue, concat(',',split(native_queue,',')[500]))[0],',')) as cid_id
+           |explode(native_queue) as cid_id
            |from native_data
-         """.stripMargin
+          """.stripMargin
       ).withColumn("label",lit(0))
       native_data1.createOrReplaceTempView("native_data1")
       println("native_explode_count",native_data1.count())