你的浏览器禁用了JavaScript, 请开启后刷新浏览器获得更好的体验!
就是对应数据库的一个update操作，update_before是前镜像值，update_after是后镜像值，比如将mysql中一行数据的一个字段从'aa'改成'bb'，那对应的两条记录就是 [-U, (key, aa)] [+U,(key, bb)]， flink sql 里是将一个update操作拆分成两条记录处理的，有些同步工具里则是记录成一条。
大数据领域最专业的产品&技术交流社区，专注于探讨与分享大数据领域有趣又火热的信息，专业又专注的数据人园地
求教一下各位大佬，flinkcdc里面，row格式数据，记录操作类型，UPDATE_BEFORE和UPDATE_AFTER有什么区别呢 
匿名用户
发布于 2022-04-11 14:32
603
1
