你好,请问下这个代码能参考下么,没法实现flink cdc执行删除操作
参考官方文档不需要额外写代码,利用flink sql可以实现,参考 https://docs.starrocks.io/zh-cn/main/loading/Flink_cdc_load
这个文档里完全没有SQL实现,不用管op,before,after吗
不用,connector做了适配