chagn

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

@@ -79,7 +79,7 @@ object testt {
           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)
+              val exposure_data_lists:List[Any] = JSON.parseFull(rowAppFieldMap("exposure_data").toString).get.asInstanceOf[List[Any]]
               println(exposure_data_lists)
             }
           })