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来着?
各位好 ,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 实现不来吗
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。