chang

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

@@ -73,15 +73,13 @@ object testt {
          """.stripMargin
           )
           get_data_dura.printSchema
+          println(get_data_dura)
           val test = get_data_dura.show(5)
 
 
           val result = get_data_dura.rdd.map(row =>{
-            val rowAppFieldMap:Map[String,Any] = row.getAs[Map[String,Any]]("params")
-            if (rowAppFieldMap.contains("duration")){
-              val exposure_data_lists:List[Any] = JSON.parseFull(rowAppFieldMap("exposure_data").toString).get.asInstanceOf[List[Any]]
-              println(exposure_data_lists)
-            }
+            val rowAppFieldMap:Map[String,Any] = row.getAs[Map[String,Any]]("partition_date")
+
           })
          // println(rows(1))  这样会报错
         }