以Dinky 为基础实现的一个“实时数据采集处理”平台: 1> 更完善的Flink的数据类型处理、 2> 增加FlinkSQL代码生成处理,含事实表、维表 3> 增加FlinkSQL代码调整功能、支持调试任务超时关闭 4> 增加FlinkSQL关键信息片断化代码替换、 5> 完善任务状态流转处理,任务生命周期自洽性,集群状态验证 6> 完善任务运行生命周期后台监控 7> 简化任务保存点保存与新任务
flink-connector-jdbc 目前源码来自于flink1.16,会放到flink1.17中 增加对达梦数据库的支持(dameng V8)
Flink CDC 研究
数据实时集后,进行数据传输
Spring Cloud学习
文件上传,与文件收集 1> 支持flink环境运行和JavaSE环境运行,业务逻辑公用; 2> 支持http、grps、websocket三种文件传输通道; 3> 源、目标文件读取支持sftp、ftp、oss、本地文件;
最近一年贡献:0 次
最长连续贡献:0 日
最近连续贡献:0 日
贡献度的统计数据包括代码提交、创建任务 / Pull Request、合并 Pull Request,其中代码提交的次数需本地配置的 git 邮箱是 Gitee 帐号已确认绑定的才会被统计。