Commit 0fac821e authored by 张彦钊's avatar 张彦钊

add

parent dab2a1cf
......@@ -68,8 +68,10 @@ if __name__ == '__main__':
tmp = rdd.collect()[0]
total.append(tmp)
print("total")
print(total)
df.unpersist()
spark.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