如何将 Scala Spark DataFrames 模式导出到 Json 文件

Question

我已经尝试过df.write.json("myNewJson")虽然没有抛出任何错误或警告，但它只是没有在目标中创建任何文件。 df.write.format("json").save("/MyDir/")似乎也有同样的问题。我在这里错过了一些陈述吗？

Answer 1

发布对

我有用的确切代码，供那些可能偶然发现相同问题的人使用。我能够使用以下语句将数据帧架构导出到 Json 文件：

import java.io._
val a = df.schema.json
val writer = new PrintWriter(new File("/home/file"))
writer.write(a)
writer.close()

Answer 2

df.write用于

保存 DF 的内容，而df.schema用于 DF 的结构。您的数据帧可能为空。您可以在保存前通过df.show()进行检查。