开发者社区大数据与机器学习实时计算 Flink 正文

kafka的数据通过flinksQL建立出来了，但是怎么去除kafka中的嵌套json?

kafka的数据通过flinksQL建立出来了，但是怎么去除kafka中的嵌套json?就是kafka中的after是一个嵌套的jsoN

展开

收起

wenti 2023-02-14 13:51:00 359 版权

1 条回答

写回答

取消提交回答

665661

使用ROW类型和ARRAY类型，基本能处理嵌套，另外可以结合UDF——该回答整理自钉群“【③群】Apache Flink China社区”

2023-02-14 16:45:11

赞同展开评论

问答分类：

消息中间件 JSON Kafka 数据格式云消息队列 Kafka 版实时计算 Flink版

问答标签：

JSON数据 JSON嵌套数据JSON 云消息队列 Kafka 版数据云消息队列 Kafka 版json

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

flink sql输出到upsert kafka 下游再消费一般是upsert 还是 json呀？

115

flinksql写kafka，有时输出数据连续，有时却不连续？？

134

flink kafka debezium-json读取更新的数据，没有op 怎么获取op为u的数据？

351

flinksql消费kafka然后look up join doris纬表，出现下面问题怎么解决？

125

flinkcdcSQL处理Kafka数据，json数据是数组的，建表结构该怎么写？[{},{}]。？

142

在机器学习PAI中，有没有用flinkSQL直接连kafka的？

kafka写入的数据如果是json数组，可以批量写入到tablestore吗？

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段？

如果用flinksql的方式同步mysql数据到kafka，是类似DTS那样吗？

Flink CDC配置true以后下游kafka的canal-json内容里没有包怎么办？

114

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

FastJson 完全学习指南（初学者从零入门）

Bean的生命周期：从Spring的子宫到坟墓

告别AI“纸上谈兵”？解锁LangGraph+OceanBase数据融合构建Agent蓝图

分布式爬虫的全局请求间隔协调与IP轮换策略

AI应用工程师面试问题清单

kafka的数据通过flinksQL建立出来了，但是怎么去除kafka中的嵌套json?

实时计算 Flink

相关文章

热门讨论

热门文章