Commit c9a24633 authored by 王志伟's avatar 王志伟

统计alpha点击

parent 7ed6baad
......@@ -691,11 +691,11 @@ object add_knowledge_network {
import sc.implicits._
val input = sc.sparkContext.textFile("/home/wangzhiwei/mouse_knowledge.csv").map(row =>row.split(",")).
toDF("project","relationship","property")
val input = sc.sparkContext.textFile("/home/wangzhiwei/mouse_knowledge.csv").map(row =>row.split(",")).toDF()
input.show()
GmeiConfig.writeToJDBCTable(input, "Knowledge_network", SaveMode.Append)
// GmeiConfig.writeToJDBCTable(input, "Knowledge_network", SaveMode.Append)
}
......
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