Skip to content

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

更改时间

parent 9ad4e825
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
eda/feededa/src/main/scala/com/gmei/data_feed_exposure_precise.scala
View file @ 2df1c3df
...@@ -760,7 +760,7 @@ object tag_value { ...@@ -760,7 +760,7 @@ object tag_value {
val result = temp2.select("tag_level").distinct().withColumn("index", row_number().over(w)) val result = temp2.select("tag_level").distinct().withColumn("index", row_number().over(w))
result.show() result.show()
val tag_level_index=result.rdd.map(row=>(row(0).toString,row(1).toString)).map(row=>(row._1.split(",").head,row._1.split(",")(1),row._2)).toDF("tag_id","level_id","index") val tag_level_index=result.rdd.map(row=>(row(0),row(1))).map(row=>(row._1.split(",").head,row._1.split(",")(1),row._2)).toDF("tag_id","level_id","index")
println("开始写入") println("开始写入")
GmeiConfig.writeToJDBCTable("jdbc:mysql://172.16.40.158:4000/jerry_prod?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",tag_level_index, table="tag_level_index",SaveMode.Overwrite) GmeiConfig.writeToJDBCTable("jdbc:mysql://172.16.40.158:4000/jerry_prod?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",tag_level_index, table="tag_level_index",SaveMode.Overwrite)
......
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