Commit 1298a50f authored by 张彦钊's avatar 张彦钊

change test file

parent dddaef01
...@@ -203,7 +203,7 @@ def test(): ...@@ -203,7 +203,7 @@ def test():
.map(lambda x:(x[1],x[0][0],x[0][1]))).toDF("ind","k","v") .map(lambda x:(x[1],x[0][0],x[0][1]))).toDF("ind","k","v")
df.show(6) df.show(6)
df.write.csv('/recommend/tr', mode='overwrite', header=True) # df.write.csv('/recommend/tr', mode='overwrite', header=True)
df.write.format("avro").mode("overwrite").save("/recommend/tr/avro.csv") df.write.format("avro").mode("overwrite").save("/recommend/tr/avro.csv")
......
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