Flink CDC 里mysql的cdc出来的json op字段有哪几种值?是 c r u d 吗?

Flink CDC 里mysql的cdc出来的json op字段有哪几种值?是 c r u d 吗?

【Linux环境】centos安装mysql5.7.26报 ./mysqld: error while loading shared libraries: libaio.so.1: cannot op

【Linux环境】centos安装mysql5.7.26报 ./mysqld: error while loading shared libraries: libaio.so.1: cannot op

在Linux服务器上安装MySQL过程中,解压完并修改完配置文件之后进行数据库初始化的时候报./mysqld: error while loading shared libraries: libaio.so.1: cannot open shared object file: No such fil...

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

RDS MySQL 高效设计及性能调优

1 课时 |
802 人已学 |
免费
开发者课程背景图

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否捕获使用?

问题1:请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否捕获使用(比如写入临时表进行使用)?现在这样写能够print出op列,但不能写入数据库?问题2:加上这个op_ts列吗?这个似乎是本地时间戳,不是 +U,+I,-U这一类型呀。能否指教更多一点?

请问Flink CDC这个mysql-cdc输出的op列能否写入临时表进行使用?

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否写入临时表进行使用?现在这样能够print,但不能写入数据库?

请问这个mysql-cdc输出的op列(黄框)能否写入临时表进行使用?

请问这个mysql-cdc输出的op列(黄框)能否写入临时表进行使用?

Flink CDC读取mysql到kafka,更新的话op不应该是u吗,出来是d和c?

Flink CDC读取mysql到kafka,更新的话op不应该是u吗,出来是d和c?

为什么mysql的insert操作是op=r,什么操作会使op=c?

为什么mysql的insert操作是op=r,什么操作会使op=c?

请问为什么我进行mysql数据update时,kafka中采集到的是先删除原纪录(op d)再新增新

请问为什么我进行mysql数据update时,kafka中采集到的是先删除原纪录(op d)再新增新纪录(op c),而不是新增新纪录(op u)。

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

产品推荐

社区圈子

阿里云数据库
阿里云数据库
让用户数据永远在线,让数据无缝的自由流动
279460+人已加入
加入
相关电子书
更多
PolarDB-X:更具性价比的 MySQL替换
2023云栖大会:AnalyticDB MySQL新特性介绍
2023云栖大会:云数据库RDS - 年度产品发布与最佳实践
立即下载 立即下载 立即下载
相关镜像