Flink CDC中大家在用oracle cdc是否支持带分区的表呀?
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 等。
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 社区论坛,以获取更准确和最新的信息。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。