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

Flink CDC中大家在用oracle cdc是否支持带分区的表呀?

Flink CDC中大家在用oracle cdc是否支持带分区的表呀?

展开
收起
真的很搞笑 2023-07-13 12:07:03 157 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    Flink CDC 支持抓取 Oracle 数据库中的带分区表。在使用 Oracle CDC 连接器时,需要在配置中指定分区列的名称和类型。

    下面是一个示例 Oracle CDC 连接器的配置,其中指定了分区列的名称为 PARTITION_COLUMN,分区列的类型为 VARCHAR:

    ini
    Copy
    connector.name=oracle-cdc
    connection-url=jdbc:oracle:thin:@//localhost:1521/ORCL
    table-name=MY_TABLE
    table-name.delimiter=.
    partition.column.name=PARTITION_COLUMN
    partition.column.type=VARCHAR
    username=MY_USERNAME
    password=MY_PASSWORD
    需要注意的是,在使用 Oracle CDC 连接器抓取带分区表时,需要确保 Oracle 数据库版本支持增量数据抓取和数据同步,并且需要在数据库中创建一个增量抓取用户,并授予相应的权限。

    此外,Flink CDC 还支持其他数据库的增量数据抓取和数据同步,例如 MySQL、PostgreSQL、SQL Server、MongoDB 等。

    2023-07-30 09:37:29
    赞同 展开评论 打赏
  • Flink CDC 支持使用 Oracle CDC 连接器来捕获 Oracle 数据库的变化数据,但是否支持带分区的表取决于具体的 Flink 版本和 CDC 连接器的实现。

    根据我所了解,目前(截至2021年),Flink 1.13 版本及更早版本的 Oracle CDC 连接器不直接支持带分区的表。这意味着在使用 Oracle CDC 连接器时,您可能需要手动对分区进行处理,例如通过应用自定义逻辑或使用 Flink 的转换操作来处理分区信息。

    然而,Flink 社区一直在不断改进和更新 CDC 连接器,使其能够更好地支持各种数据库和表结构。因此,随着 Flink 版本的更新,未来的 Oracle CDC 连接器可能会添加对带分区表的原生支持。

    如果您具体使用的是 Flink 的最新版本,并且想要了解有关 Oracle CDC 连接器是否支持带分区表的详细信息,我建议您查阅 Flink 官方文档、邮件列表或 Flink 社区论坛,以获取更准确和最新的信息。

    2023-07-29 22:35:26
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像