Flink CDC 里能抽取达梦数据库嘛?cdc好像不支持 批的方式 jdbc 看了好像也不行。
在flink-connector-jdbc中增加对国产数据库达梦(V8)的支持
flink-connector-jdbc是Apache Flink框架提供的一个用于与关系型数据库进行连接和交互的连接器。它提供了使用Flink进行批处理和流处理的功能,可以方便地将关系型数据库中的数据引入Flink进行分析和处理,或者将Flink计算结果写入关系型数据库。
flink-connector-jdbc可以实现以下核心功能:
数据源连接:可以通过flink-connector-jdbc连接到各种支持JDBC标准的关系型数据库,如MySQL、PostgreSQL、Oracle等。
数据写入:可以将Flink的计算结果写入关系型数据库中,实现数据的持久化。
数据读取:可以从关系型数据库中读取数据,并将其作为Flink计算的输入数据。
数据格式转换:可以将关系型数据库中的数据转换为适合Flink计算的数据格式。
并行处理:可以根据数据源的并行度将数据进行分区和并行处理,以加速数据处理的速度。
flink-connector-jdbc为Flink提供了与关系型数据库集成的能力,可以方便地进行数据的导入、导出和处理,为开发人员提供了更强大和灵活的数据处理能力。
参考 https://blog.csdn.net/u010782920/article/details/132629644
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。