我在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/