如何提取配置单元列中存储为字符串的json,然后使用spark java将其作为结构类型添加到另一个配置单元列中?

iyzzxitl  于 2021-06-24  发布在  Hive
关注(0)|答案(0)|浏览(216)

我已经成功地将json字符串转储到字符串列的数组中。现在我想把json字符串转换成struct列。
原因-我想使用explode函数查询json数据。它使查询更加简单。
我试过下面的代码,但不起作用。

.withColumn("json_struct_col",functions.struct(functions.column("json_string_col")));

还有一个,

.withColumn("json_struct_col",functions.explode(functions.column("json_string_col").cast (new StructType())));

哪里 json_string_col 是配置单元中的列,并且 json_struct_col 是结构类型为的目标列。
事先谢谢你帮我做这件事。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题