修复bug

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

@@ -3,7 +3,7 @@ package com.gmei
 import java.io.Serializable
 
 import com.gmei.WeafareStat.{defaultParams, parser}
-import org.apache.spark.sql.{SaveMode, TiContext}
+import org.apache.spark.sql.{SaveMode}
 import org.apache.log4j.{Level, Logger}
 import scopt.OptionParser
 import com.gmei.lib.AbstractParams
@@ -43,12 +43,14 @@ object Recommendation_strategy_all {
       val spark_env = GmeiConfig.getSparkSession()
       val sc = spark_env._2
 
-      val ti = new TiContext(sc)
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "diary_video")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_click")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table")
+      sc.sql("use jerry_prod")
+
+//      val ti = new TiContext(sc)
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "diary_video")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_click")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table")
 
 
       val stat_date = GmeiConfig.getMinusNDate(1)
@@ -403,11 +405,11 @@ object Gini_coefficient {
       val spark_env = GmeiConfig.getSparkSession()
       val sc = spark_env._2
 
-      val ti = new TiContext(sc)
-      ti.tidbMapTable(dbName = "eagle", tableName = "src_mimas_prod_api_diary")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_click")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
-      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
+//      val ti = new TiContext(sc)
+//      ti.tidbMapTable(dbName = "eagle", tableName = "src_mimas_prod_api_diary")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_click")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
+//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
 
 
       import sc.implicits._
@@ -419,7 +421,7 @@ object Gini_coefficient {
       val diary_id = sc.sql(
         s"""
            |select id as diary_id
-           |from src_mimas_prod_api_diary
+           |from eagle.src_mimas_prod_api_diary
            |where content_level >=3.5
            |and doctor_id is not null
          """.stripMargin

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

@@ -3,7 +3,7 @@ package com.gmei
 import java.io.Serializable
 
 import com.gmei.WeafareStat.{defaultParams, parser}
-import org.apache.spark.sql.{SaveMode, TiContext}
+import org.apache.spark.sql.{SaveMode}
 import org.apache.log4j.{Level, Logger}
 import scopt.OptionParser
 import com.gmei.lib.AbstractParams

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

@@ -2,7 +2,7 @@ package com.gmei
 
 import java.io.Serializable
 
-import org.apache.spark.sql.{SaveMode, TiContext}
+import org.apache.spark.sql.{SaveMode}
 import org.apache.log4j.{Level, Logger}
 import scopt.OptionParser
 import com.gmei.lib.AbstractParams