统计alpha点击

7ed6baad · 王志伟 · f9f054dc · 7ed6baad
Commit 7ed6baad authored Apr 03, 2019 by 王志伟
Show whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

temp_analysis.scala eda/feededa/src/main/scala/com/gmei/temp_analysis.scala +2 -1

No files found.
--- a/eda/feededa/src/main/scala/com/gmei/temp_analysis.scala
+++ b/eda/feededa/src/main/scala/com/gmei/temp_analysis.scala
@@ -691,7 +691,8 @@ object add_knowledge_network {


      import sc.implicits._
-      val input = sc.sparkContext.textFile("/home/wangzhiwei/mouse_knowledge.csv").toDF("project","relationship","property")
+      val input = sc.sparkContext.textFile("/home/wangzhiwei/mouse_knowledge.csv").map(row =>row.split(",")).
+        toDF("project","relationship","property")


      GmeiConfig.writeToJDBCTable(input, "Knowledge_network", SaveMode.Append)