Skip to content

F
ffm-baseline
Commit c04c4706 authored by 王志伟's avatar 王志伟
Browse files
Options

修复bug

parent 7fc3bb53
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 4 deletions
eda/feededa/src/main/scala/com/gmei/Data2FFM.scala
View file @ c04c4706
...@@ -3,7 +3,7 @@ import java.io.{File, PrintWriter, Serializable} ...@@ -3,7 +3,7 @@ import java.io.{File, PrintWriter, Serializable}
import com.gmei.lib.AbstractParams import com.gmei.lib.AbstractParams
import org.apache.log4j.{Level, Logger} import org.apache.log4j.{Level, Logger}
import org.apache.spark.sql.{DataFrame, SaveMode, TiContext} import org.apache.spark.sql.{DataFrame, SaveMode}
import scopt.OptionParser import scopt.OptionParser
...@@ -47,9 +47,11 @@ object Data2FFM { ...@@ -47,9 +47,11 @@ object Data2FFM {
val spark_env = GmeiConfig.getSparkSession() val spark_env = GmeiConfig.getSparkSession()
val sc = spark_env._2 val sc = spark_env._2
val ti = new TiContext(sc) sc.sql("use jerry_test")
ti.tidbMapTable(dbName = "jerry_test", tableName = "esmm_train_data")
ti.tidbMapTable(dbName = "jerry_test", tableName = "esmm_pre_data") // val ti = new TiContext(sc)
// ti.tidbMapTable(dbName = "jerry_test", tableName = "esmm_train_data")
// ti.tidbMapTable(dbName = "jerry_test", tableName = "esmm_pre_data")
val train_sep_date = GmeiConfig.getMinusNDate(10) val train_sep_date = GmeiConfig.getMinusNDate(10)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment