如何将 Scala Spark DataFrames 模式导出到 Json 文件?
How can I export Scala Spark DataFrames schema to a Json file?
我试过 df.write.json("myNewJson")
虽然没有抛出任何错误或警告,但它只是没有在目标中创建任何文件。 df.write.format("json").save("/MyDir/")
好像也有同样的问题。我在这里错过了一些声明吗?
df.write
用于保存df的content,而df.schema
用于structure df。您的 DataFrame 可能是空的。保存前可以df.show()
查看
为那些可能偶然发现同样问题的人发布对我有用的确切代码。
我能够使用以下语句将 DataFrame 模式导出到 Json 文件:
import java.io._
val a = df.schema.json
val writer = new PrintWriter(new File("/home/file"))
writer.write(a)
writer.close()
我试过 df.write.json("myNewJson")
虽然没有抛出任何错误或警告,但它只是没有在目标中创建任何文件。 df.write.format("json").save("/MyDir/")
好像也有同样的问题。我在这里错过了一些声明吗?
df.write
用于保存df的content,而df.schema
用于structure df。您的 DataFrame 可能是空的。保存前可以df.show()
查看
为那些可能偶然发现同样问题的人发布对我有用的确切代码。 我能够使用以下语句将 DataFrame 模式导出到 Json 文件:
import java.io._
val a = df.schema.json
val writer = new PrintWriter(new File("/home/file"))
writer.write(a)
writer.close()