开发者社区> 问答> 正文

Flink SQL 解析复杂(嵌套)JSON 的问题以及写入到 hive 映射问题

json格式,如果是一个json数组的方法定义模式,数组里还可能存在隐藏json数组的情况。

如数据: {"user_info":{"user_id":"0111","name":"xxx"},"timestam":1586676835655,"id":"10001","jsonArray":[{"name222":"xxx" ,"user_id222":"0022"},{"name333":"name3333","user_id222":"user3333"},{"cc":"xxx333","user_id444":"user4444","name444":" name4444"}]}

参照:https://www.cnblogs.com/Springmoon-venn/p/12664547.html 需要模式这样定义: user_info 定义成:ROW<user_id STRING, name STRING> jsonArray 定义成: ARRAY<ROW<user_id222 STRING, name222 STRING>>

问题是: 如果json数组还有一个数组可以编码定义吗?这个数据也是要写入到hive,数组里,数组 ,怎么映射成Hive类型,映射成数组 ,这种情况的json怎么处理? 有没有什么办法直接把json数组,直接映射成数组 ,试过发现不行,怎么处理这种复杂类型。*来自志愿者整理的flink邮件归档

展开
收起
小阿怪 2021-12-07 10:04:05 1091 0
1 条回答
写回答
取消 提交回答
  • json格式有一个问题在解这个问题[1],可以把jsonNode强制转成字符串,1.12里会支持,可以看下。

    最好的事物 伦纳德 [1] https://issues.apache.org/jira/browse/FLINK-18002 < https://issues.apache.org/jira/browse/FLINK-18002 >*来自志愿者整理的flink邮件归档

    2021-12-07 11:44:01
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载