【发布时间】:2019-04-04 10:37:17
【问题描述】:
我有一个带有 3 个字段的 dataframe,我想将其转换为 JSON 数据格式。
注意:我使用的是数据块。
DF:
+-------+----+----------+---------|
|Airline|Type|Account No|Ticket No|
+-------+----+----------+---------+
| B0| 06| 12345| PNR12456|
| B1| 07| 4589| PNR6588|
+-------+----+----------+---------|
我想把它转换成JSON格式:
{
"Airline":{B0,B1...},
"Type":{06,07,....},
"Account No":{1234,4589,....},
"Ticket No":{PNR12456,PNR6588,....}
}
我使用过以下代码:
DF.to_json(orient='records')
我想在 Scala Spark 中执行它。
【问题讨论】:
标签: scala apache-spark