当前位置:网站首页>spark 避免对一个列重复解析json

spark 避免对一个列重复解析json

2022-06-10 06:29:00 健忘主义

table(s"${bakdb}.${body_dossier_930_bak}")
//            .withColumn("dossier_id",get_json_object($"result","$.dossierId"))
//            .withColumn("create_time",get_json_object($"result","$.createTime"))
            .select(
                $"*"
                ,json_tuple($"result","dossierId","createTime").as(Seq("dossier_id","create_time"))
            )

使用 json_tuple 

原网站

版权声明
本文为[健忘主义]所创,转载请带上原文链接,感谢
https://yangyong.blog.csdn.net/article/details/125104958