开发者社区> 问答> 正文

请问Flink1.10怎么样定义kafka中消息为json数组对象的情况呀?

网上有非常多的资料显示Flink SQL怎样定义嵌套的json属性以及json中某个属性为json数组的示例, 但是对于整个消息为一个数组(json array)的应该怎么处理? json示例如下: [ { "a": "1", "b": 2 } ]*来自志愿者整理的FLINK邮件归档

展开
收起
又出bug了-- 2021-12-03 17:36:15 849 0
1 条回答
写回答
取消 提交回答
  • 这个功能暂时还没有,FLIP-124[1] 之后应该是可以的。

    [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148645988*来自志愿者整理的FLINK邮件归档

    2021-12-03 18:08:39
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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