spark dataframe将所有列转换为json格式,然后修改json结构

khbbv19g  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(793)

使用df.tojson将我的Dataframe转换为json
json转换后,模式如下所示:

root
 |-- value: string (nullable = true)

创建当前模式的最佳方法是什么(即,所有根级属性;在本例中,'value'列)嵌套到新的根级json键(称为'data')中,并在根级添加新属性。如何在scala中实现这一点。

agxfikkp

agxfikkp1#

请检查下面的代码。

scala> df.toJSON.select(struct($"value").as("data")).printSchema
root
 |-- data: struct (nullable = false)
 |    |-- value: string (nullable = true)

相关问题