Commit 5ce555c9 authored by 张彦钊's avatar 张彦钊

修改rdd

parent 8cc061c7
......@@ -60,7 +60,7 @@ object Data2FFM {
).na.drop()
esmm_data.show(8)
println(esmm_data.count())
esmm_data.createOrReplaceTempView("df")
esmm_data.createOrReplaceGlobalTempView("df")
val sql1 = "select * from df"
val df = sc.sql(sql1)
......
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