flink 怎么实现监控表中数据的变更?[阿里云实时计算 Flink版]

flink 怎么实现监控表中数据的变更,并将变更的数据给打印出来,好比我flink cdc 同步db2的数据,但是我只想拿到update的数据,别的事务的数据不关心,(ps:这个op没有update,他这个里面的update操作是先删除op=-D然后再插入一条新的op=+I,没法判断,如果我单单过滤op=D的可能是删除操作)

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====