我在python中使用Databricks将JSON文件的最终结构更改为dataFrame。
要在Databricks中阅读,可以使用:

df = sqlContext.sql("SELECT * FROM people")


使用Jupyter笔记本时,您可以轻松实现以下目的:

df = spark.read.json('people.json', schema = final_struc)


但是它如何在数据块中工作?

最佳答案

有时,您应该在文件所在的位置添加路径名,以便它可能起作用。喜欢

df = spark.read.json('FileStore/Something/people.json', schema = final_struc)


希望这行得通。

关于python - 使用databricks更改dataFrame中JSON文件的最终结构?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/44439794/

10-11 20:29
查看更多