logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

FlinkSQL(JDBC)支持谓词下推、支持复杂SQL查询、并行度、CLOB

摘要:本文针对FlinkSQL(JDBC)在离线数据同步中的四个常见问题提出解决方案:1)通过修改源码增加DATA_FILTER属性实现部分数据同步;2)新增CUSTOM_SQL属性支持关联表筛选;3)引入scan.parallel系列属性实现无递增字段时的并行采集;4)支持Oracle CLOB类型解析。

#flink
FlinkSQL支持HANA数据库离线采集

摘要:本文介绍了为FlinkSQL添加SAP HANA数据库支持的源码修改。主要包括创建HanaDialect类实现数据库方言支持,定义数据类型转换、SQL语法特性等;开发HanaDialectFactory工厂类用于识别HANA连接URL;编写HanaRowConverter处理数据类型转换。最后在META-INF/services中注册方言工厂类。这些修改使FlinkSQL能够通过JDBC连接

#flink
FlinkSQL支持HANA数据库离线采集

摘要:本文介绍了为FlinkSQL添加SAP HANA数据库支持的源码修改。主要包括创建HanaDialect类实现数据库方言支持,定义数据类型转换、SQL语法特性等;开发HanaDialectFactory工厂类用于识别HANA连接URL;编写HanaRowConverter处理数据类型转换。最后在META-INF/services中注册方言工厂类。这些修改使FlinkSQL能够通过JDBC连接

#flink
FlinkSQL(JDBC)支持谓词下推、支持复杂SQL查询、并行度、CLOB

摘要:本文针对FlinkSQL(JDBC)在离线数据同步中的四个常见问题提出解决方案:1)通过修改源码增加DATA_FILTER属性实现部分数据同步;2)新增CUSTOM_SQL属性支持关联表筛选;3)引入scan.parallel系列属性实现无递增字段时的并行采集;4)支持Oracle CLOB类型解析。

#flink
到底了