更改时间

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

@@ -8,11 +8,11 @@ import org.apache.spark.sql.SaveMode
 import org.apache.log4j.{Level, Logger}
 import scopt.OptionParser
 import com.gmei.lib.AbstractParams
-//import com.sun.deploy.uitoolkit.Window
 
 import org.apache.spark.sql.expressions.Window
 import org.apache.spark.sql.functions.row_number
 
+
 object data_feed_exposure_precise {
 
   Logger.getLogger("org.apache.spark").setLevel(Level.WARN)
@@ -654,6 +654,7 @@ object tag_value {
       val sc = spark_env._2
 
       sc.sql("use jerry_prod")
+      import sc.implicits._
 
 
       val stat_date = GmeiConfig.getMinusNDate(1)
@@ -759,6 +760,8 @@ object tag_value {
       val result = temp2.select("tag_level").distinct().withColumn("index", row_number().over(w))
       result.show()
 
+      val test=result.rdd.map(row=>(row(0).toString,row(1).toString)).map(row=>(row._1.split(",").head,row._1.split(",")(1),row._2)).toDF().show()
+