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

Flink CDC默认是啥模式?

Flink CDC默认是啥模式?

展开
收起
游客uu65yiq7myioi 2023-02-27 12:28:24 204 0
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版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载