Commit c2e0c486 authored by 张彦钊's avatar 张彦钊

修改测试文件

parent 30554f04
......@@ -62,7 +62,7 @@ def feature_engineer():
"where e.stat_date >= '{}'".format(start)
df = spark.sql(sql)
df.write.csv("file:/home/gmuser/esmm/hello.csv")
df.write.csv("file:/home/gmuser/hello.csv")
# url = "jdbc:mysql://172.16.30.143:3306/zhengxing"
# jdbcDF = spark.read.format("jdbc").option("driver", "com.mysql.jdbc.Driver").option("url", url) \
......
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