使用df.tojson将我的Dataframe转换为jsonjson转换后,模式如下所示:
root |-- value: string (nullable = true)
创建当前模式的最佳方法是什么(即,所有根级属性;在本例中,'value'列)嵌套到新的根级json键(称为'data')中,并在根级添加新属性。如何在scala中实现这一点。
agxfikkp1#
请检查下面的代码。
scala> df.toJSON.select(struct($"value").as("data")).printSchema root |-- data: struct (nullable = false) | |-- value: string (nullable = true)
1条答案
按热度按时间agxfikkp1#
请检查下面的代码。