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

Flink CDC这块是view,被优化拆分两部分,有没有办法共用一个view?

Flink CDC这块是view,被优化拆分两部分,有没有办法共用一个view?image.png

展开
收起
cuicuicuic 2023-12-04 07:31:50 23 0
3 条回答
写回答
取消 提交回答
  • 这个看业务,理论是可以的 ,此回答整理自钉群“Flink CDC 社区”

    2023-12-05 08:27:41
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink CDC 是一种可以捕获数据库变更的技术,其核心思想是监测并捕获数据库的变动,包括数据或数据表的插入、更新和删除等操作。然而,关于你所提问的是否有办法共用一个view,这个问题的答案可能取决于具体的使用场景和需求。在一般情况下,每个 Flink CDC 任务都会对应一个特定的 view,因为它们可能需要处理不同的数据变更。然而,如果你能确保两个任务之间的数据变更不会相互影响,那么理论上也是可以考虑共用一个 view 的。这就需要你根据实际情况来权衡利弊了。

    2023-12-04 14:30:07
    赞同 展开评论 打赏
  • Flink CDC的工作原理是通过监听数据库的变更事件,然后将这些变更事件应用到视图(View)上,从而实现数据的同步。如果你的视图被优化拆分为两个部分,那么Flink CDC需要分别对这两个部分进行同步。

    在Flink中,视图(View)是一个虚拟表,它基于其他表的查询结果生成。视图可以被看作是一个预定义的查询语句的结果集。因此,如果你想让Flink CDC共用一个视图,你需要确保这个视图能够包含两个部分的变更数据。

    具体来说,你可以考虑以下几种方式:

    1. 修改视图的定义:你可以尝试修改视图的定义,使其能够包含两个部分的变更数据。例如,你可以将两个部分的变更数据合并到一个表中,然后基于这个表创建视图。

    2. 使用联合(UNION)查询:你可以使用联合(UNION)查询来组合两个部分的变更数据,然后基于这个联合查询结果创建视图。

    3. 使用子查询:你可以使用子查询来获取两个部分的变更数据,然后基于这个子查询结果创建视图。

    2023-12-04 11:59:25
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

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