将changlog转换成为数据库的增删改查操作

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

将changlog转换成为数据库的增删改查操作最先出现在Python成神之路。