【发布时间】:2021-11-25 14:26:00
【问题描述】:
我已经开始使用数据块,我正在使用社区云,我正在尝试读取 json 文件。 我尝试按以下方式执行此操作:
from pyspark.sql import SparkSession
df=spark.read.json('people')
但是我得到了错误:
IllegalArgumentException:路径必须是绝对的:人
我尝试使用不同的文字来访问 people.json 文件:
'people.json', '/people.json','Data/deafult/people' 等,最后一个是基于我了解的数据存储位置:
但是,这不起作用,我一直收到相同的错误消息。
Ho每当我尝试使用 sql.Context.sql 读取它时,它都会显示表格:
df=sqlContext.sql("SELECT * FROM people")
df.show()
>>>
+----+-------+
| age| name|
+----+-------+
|null|Michael|
| 30| Andy|
| 19| Justin|
+----+-------+
所以我的问题是如何使用 spark.read.json 打开 json 文件?
【问题讨论】:
标签: json dataframe pyspark databricks