选取native_queue 500条日记改为选取native_queue所有日记

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

@@ -333,7 +333,7 @@ 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
       ).withColumn("label",lit(0))