Flink CDC默认是啥模式?

Flink CDC默认是啥模式?

展开
收起
wenti 2023-02-27 12:28:24 305 分享 版权
2 条回答
写回答
取消 提交回答
  • 资深技术专家。主攻技术开发,擅长分享、写文、测评。

    Flink CDC(Change Data Capture)默认采用的是追加模式(Append Mode)。在追加模式下,Flink CDC会将新到达的数据添加到数据流的末尾,不对已有的数据进行修改或删除。这种模式适合处理流数据,例如对于一条订单记录,只需要将新的订单添加到订单记录的末尾,不需要修改或删除之前的订单记录。

    除了追加模式,Flink CDC还支持更新模式(Update Mode)和撤回模式(Retract Mode)。在更新模式下,Flink CDC会在数据流中更新旧的数据,例如更新一条用户信息。在撤回模式下,Flink CDC会从数据流中删除旧的数据,例如撤回一条订单记录。这两种模式适合处理批数据,因为需要对已有的数据进行修改或删除。

    2023-02-27 21:30:37
    赞同 展开评论
  • 应该是binlog模式

    2023-02-27 13:00:59
    赞同 展开评论

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

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理