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

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

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

展开

收起

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

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呀？

123

如何通过Kafka Connector解析嵌套JSON格式的数据

184

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

140

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

373

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

126

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

146

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

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

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

101

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

大数据与机器学习

实时计算 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，提供丰富的企业级增值功能。

亚马逊：调用跨境物流API追踪国际包裹清关状态，优化时效

MyBatis SQL 返回 resultType="map"

拼多多：通过物流预警API提前识别异常订单，主动联系用户

常用SpringBoot注解汇总与用法说明

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

实时计算 Flink

相关文章

热门讨论

热门文章