如何将Scala Spark DataFrames架构导出到Json文件？

发布时间：2020-12-16 09:04:35 所属栏目：安全来源：网络整理

导读：我尝试过df.write.json(“myNewJson”)虽然没有抛出任何错误或警告但它根本不会在目标中创建任何文件. df.write.format(“json”).save(“/ MyDir /”)似乎也有同样的问题.我在这里错过了一些陈述吗？解决方法为那些可能偶然遇到同样问题的人发布适用于我

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

解决方法

为那些可能偶然遇到同样问题的人发布适用于我的确切代码.
我能够使用以下语句将DataFrame模式导出到Json文件：

import java.io._

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!