1

火花:2.4.4 Pyspark

我已经注册了临时表并尝试将输出保存到 csv 文件。但得到错误为 “AttributeError:'NoneType'对象没有属性'write'”

data.registerTempTable("data")
output = spark.sql("SELECT col1,col2,col3 FROM data").show(truncate = False)

output.write.format('.csv').save("D:/BPR-spark/sourcefile/filtered.csv")

请帮忙

4

1 回答 1

4

您将show()的结果分配给变量output并且show()不返回值。

因此,您想将 Dataframe 分配给 variable output,然后像这样保存它:

data.registerTempTable("data")
output = spark.sql("SELECT col1,col2,col3 FROM data")
output.write.format('.csv').save("D:/BPR-spark/sourcefile/filtered.csv")
于 2019-09-26T10:22:38.600 回答