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

Flink CDC中datastream里面的tablelist怎么表达?

Flink CDC中datastream里面的tablelist怎么表达除了a.tablename的所有表 正常是a.*?

展开
收起
真的很搞笑 2024-03-05 23:28:58 37 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    在Flink CDC中,tableList用于指定要捕获的表列表。如果你想表达除了某个表之外的所有表,可以使用通配符(*)来匹配所有表,然后排除特定的表名。

    假设你要捕获除了"a.tablename"之外的所有表,你可以使用以下方式来配置tableList

    tableList = "*"; // 匹配所有表
    excludeTables = "a.tablename"; // 排除特定的表名
    

    通过将tableList设置为"*",可以匹配所有表,然后通过设置excludeTables为"a.tablename",可以排除特定的表名。这样,Flink CDC将会捕获除了"a.tablename"之外的所有表的数据变更。

    请注意,具体的配置方式可能因使用的编程语言和框架而有所不同,上述示例是基于Java语言的假设。在实际使用时,请参考你所使用的编程语言和框架的文档以获取准确的配置方法。

    2024-03-08 23:26:31
    赞同 展开评论 打赏
  • 可以加debezium.exclude.tables来排除a.tablename ,此回答整理自钉群“Flink CDC 社区”

    2024-03-06 10:43:42
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 覃立辉 立即下载
    Flink CDC Meetup PPT - 孙家宝 立即下载
    Flink CDC Meetup PPT - 徐榜江 立即下载