将changlog转换成为数据库的增删改查操作
经过我的测试验证，下面的实现方式是可行的。 1.将changlog转换成为ROW,ROW中存在ROWKind，设置rowkind，就可以完成相关数据的增删改查操作实现的。 hudi完成对应的数据的增加改查也是使用到flink的这种特性的。 下面是实现的流程图：
经过我的测试验证，下面的实现方式是可行的。 1.将changlog转换成为ROW,ROW中存在ROWKind，设置rowkind，就可以完成相关数据的增删改查操作实现的。 hudi完成对应的数据的增加改查也是使用到flink的这种特性的。 下面是实现的流程图：
共有 0 条评论