开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

这个句话的意思是,delete时间我可以从cdc 获取_id 和 op:d?

MongoDB’s change event record doesn’t have update before message. So, we can only convert it to Flink’s UPSERT changelog stream. An upsert stream requires a unique key, so we must declare _id as primary key. We can’t declare other column as primary key, becauce delete operation do not contain’s the key and value besides _id and sharding key.

展开
收起
雪哥哥 2022-11-03 21:47:46 254 0
1 条回答
写回答
取消 提交回答
  • 是的,使用 stream api 的话,删除的时候只能获取 _id 的,delete by _id(此答案整理自Flink CDC 社区)

    2022-11-03 22:03:38
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

热门讨论

热门文章

相关电子书

更多
对 2000 多亿条数据做一次 group by 需要多久? 立即下载
对2000多亿条数据做一次Group By 需要多久 立即下载
Spark SQL:Past Present &Future 立即下载