flink-cdc同步至StarRocks,使用DataStream API如何添加_op删除操作


翻到了之前的帖子,但是还是没明白在DataStream API中哪里写入这个_op,能麻烦提供个demo示例吗?


参考下

你好,请问下这个代码能参考下么,没法实现flink cdc执行删除操作

参考官方文档不需要额外写代码,利用flink sql可以实现,参考 https://docs.starrocks.io/zh-cn/main/loading/Flink_cdc_load

这个文档里完全没有SQL实现,不用管op,before,after吗

不用,connector做了适配