chang

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

@@ -40,7 +40,7 @@ object WeafareStat {
       val sc = spark_env._2
 
       val ti = new TiContext(sc)
-      ti.tidbMapTable(dbName = "jerry_prod",tableName = "diary_video")
+      ti.tidbMapTable(dbName = "eagle",tableName = "diary_video")
       ti.tidbMapTable(dbName = "jerry_prod",tableName = "data_feed_click")
       ti.tidbMapTable(dbName = "eagle",tableName = "feed_diary_boost")
 

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

@@ -75,10 +75,15 @@ object testt {
           get_data_dura.printSchema
           get_data_dura.show(5)
 
+          val tst = get_data_dura.filter("params[duration] > 0")
+          val tst2 = tst.filter("params[duration] > 0")
+
+
+
 
 
           val result = get_data_dura.rdd.map(row =>{
-            println(row)
+            val rowa = row.
 
 
           })