flink sql数据写入kafka,会出现key为before、after及op,怎么把这些去掉?

flink sql数据写入kafka,会出现key为before、after及op,怎么把这几个去掉?我写入的数据直接是json格式

Flink CDC中flink sql 怎么过滤op来着?

Flink CDC中flink sql 怎么过滤op来着?

如何在 PolarDB-X 中优化慢 SQL

2 课时 |
113 人已学 |
免费

SQL完全自学手册

61 课时 |
3601 人已学 |
免费

SQL Server on Linux入门教程

14 课时 |
4329 人已学 |
免费
开发者课程背景图

各位好 ,Flink CDC中我这个SQL 为啥没有OP啊 我是CDC 读取oracle?我想看

各位好 ,Flink CDC中我这个SQL 为啥没有OP啊 我是CDC 读取oracle?我想看 changelog变化的

SQL api能把cdc捕获到的op操作类型在select中查出来吗?

我看官方文档好像只能获取数据库名模式名表名和时间戳四个元数据

flink SQL能获取到op字段在select里面查出来吗?

flink SQL能获取到op字段在select里面查出来吗?

通过flink sql的方式获取cdc , 能拿到cdc的op类型吗

通过flink sql的方式获取cdc , 能拿到cdc的op类型吗

请问各位大佬,这个op的状态用flink sql怎么存呀

请问各位大佬,这个op的状态用flink sql怎么存呀

这个『根据 op 值判断操作类型来自己组装 sql』是指在哪里实现?是指单纯用 Flink Tabl

这个『根据 op 值判断操作类型来自己组装 sql』是指在哪里实现?是指单纯用 Flink Table API 实现不来吗

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

社区圈子

数据库
数据库
分享数据库前沿,解构实战干货,推动数据库技术变革
253177+人已加入
加入
相关电子书
更多
PolarDB NL2SQL: 帮助您写出准确、优化的SQL
基于 Flink SQL + Paimon 构建流式湖仓新方
SQL智能诊断优化产品SQLess蚂蚁最佳实践
立即下载 立即下载 立即下载