chang

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

@@ -72,10 +72,9 @@ object testt {
                |and partition_date = ${newtime}
          """.stripMargin
           )
-          val test = get_data_dura.take(10)
-          for (i <- 0 to 9) {
-            println(test(i))
-          }
+          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")){