问答 求教一下各位大佬,flinkcdc里面,row格式数据,记录操作类型,UPDATE_BEFORE和UPDATE_AFTER有什么区别呢

求教一下各位大佬,flinkcdc里面,row格式数据,记录操作类型,UPDATE_BEFORE和UPDATE_AFTER有什么区别呢

   匿名用户    发布于 2022-04-11 14:32 最新回复 2022-04-11 14:48  来自于   群内解答  650  1
1条回答
群内解答
回复于 2022-04-11 14:48

就是对应数据库的一个update操作,update_before是前镜像值,update_after是后镜像值,比如将mysql中一行数据的一个字段从'aa'改成'bb',那对应的两条记录就是 [-U, (key, aa)] [+U,(key, bb)], flink sql 里是将一个update操作拆分成两条记录处理的,有些同步工具里则是记录成一条。

0 0
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群