Commit 2061b704 authored by 张彦钊's avatar 张彦钊

change test file

parent 352626c8
......@@ -376,7 +376,8 @@ if __name__ == '__main__':
"where e.stat_date >= '2019-06-10'"
df = spark.sql(sql)
df.save("hdfs:///strategy/esmm/native/d.csv", "com.databricks.spark.csv")
df.repartion(1).write.format('com.databricks.spark.csv').save(path + "native/a.csv", header='true')
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