【详述】问题详细描述
flink-cdc sink数据为json类型如何删除,我从mongDbcdc获取数据,sink配置类似图中代码,怎么处理删除。
我看了"StarRocksSinkOP.DELETE.ordinal();"的方式,但我还是不明白我要怎么做
【导入/导出方式】mongDbcdc获取数据,sr-connector写入
【背景】做过哪些操作?
【业务影响】
【StarRocks版本】例如:2.3
【集群规模】例如:1fe(1 follower+2observer)+3be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【附件】
starrocks表需要使用主键模型,另外json中需要有{"__op":1}表示删除,{"__op":0}表示upsert
starrocks表需要使用主键模型,另外json中需要有{"__op":1}表示删除,{"__op":0}表示upsert
这个在flink sql 中,如果要删掉cdc源删除的数据,怎么表示。