我正在尝试为一些变量使用pyspark创建一个沿袭,但我看到json在写入所需路径时不会写入空值。示例json o/p使用 df.write.format(json).save(‘to_path’)
```
{“load”:{“employee”:{”emp_id”:”123”,”department”:”science”}}}
{“load”:{“employee”:{”emp_id”:”456”}}}
我不明白 `department` 因为它在源Dataframe中为空。
更新-我使用的spark版本是2.3.2,由于组织限制,无法升级到版本3。
暂无答案!
目前还没有任何答案,快来回答吧!