Commit 625dfcb7 authored by 高雅喆's avatar 高雅喆

add esmm data

parent 44cf12a4
......@@ -120,6 +120,12 @@ object EsmmData {
println(clk_data_filter.count())
val union_data = imp_data_filter.union(clk_data_filter).union(cvr_data_filter)
union_data.show()
println("union_data.count()")
println(union_data.count())
sc.stop()
......
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