望云阁

望云阁

Flink sql connector Mysql示例

需要额外下载jar包: mysql-connector-java-8.0.20.jar flink-connector-jdbc_2.11-1.12.0.jar 下载之后将jar放入到flink-1.


gxq926  24  2021-04-15 阅读全文

Debezium 1.5.0.CR1版本发布,Oracle Connector已经稳定

Oracle连接器一直处于孵化状态,但是最近的努力帮助为连接器带来了新的功能和稳定性。至此,我们已经感觉到连接器已经准备就绪,因此在此版本中,我们正式将Oracle连接器从孵化升级为稳定。 社区的巨大


gxq926  53  阅读全文

Flink Mysql connector CDC1.2版本发布更新

该版本升级支持Flink1.12.1版本。并升级了几个重要特性 1、支持从特定的MySQL Binlog位置读取 2、支持“initial”,“earliest-offset”,“latest-off


gxq926  109  阅读全文
基于 Flink SQL 构建流批一体的 ETL 数据集成

基于 Flink SQL 构建流批一体的 ETL 数据集成

数据仓库与数据集成 数据仓库是一个集成的(Integrated),面向主题的(Subject-Oriented),随时间变化的(Time-Variant),不可修改的(Nonvolatile)数据集合


gxq926  113  阅读全文

OrientDB两实体关系最短路径算法

SELECT expand(path) FROM (  SELECT shortestPath($from, $to) AS path    LET      $from = (SELECT FROM


gxq926  105  2021-02-24 阅读全文

OrientDB相关

OrientDB目前版本为3.1.8版本,支持分布式部署。修复了分布式查询超时的bug,修改了默认语言设置,在数据库级别添加分析信息。 1、根据全局配置向SELECT查询添加超时。 2、使用单个索引条


gxq926  113  2021-02-24 阅读全文