一种Flink框架运行ETL的流程分解方法和装置
实质审查的生效
摘要
本发明涉及数据处理技术领域，提供了一种Flink框架运行ETL的流程分解方法和装置。本发明专利就ETL流程翻译转化成flink API语句操作算子链提供了一种高效稳定便利方法。不用在操作算子Function重新实现数据处理逻辑代码，不破坏流程的完整性，基本保存单服务器版ETL流程原有的顺序性，并且与单服务器ETL DAG运行逻辑一致，完全重用ETL运行流程逻辑实现；既可以使用Flink内置的算子提供的Function或内置的connector提供的Function，又可以完全使用ETL组件进行数据的计算处理；任何ETL流程都可以翻译转化成Flink API语句的操作算子链，提交给Flink框架执行，具备通用便利性，完全避免flink算子函数中人工编写数据处理逻辑代码。
基本信息
专利标题 ：
一种Flink框架运行ETL的流程分解方法和装置
专利标题（英）：
暂无
公开（公告）号 ：
CN114385136A
申请号 ：
CN202111638140.8
公开（公告）日 ：
2022-04-22
申请日 ：
2021-12-29
授权号 ：
暂无
授权日 ：
暂无
发明人 ：
高东升梅纲吴鑫胡高坤付晨玺
申请人 ：
武汉达梦数据库股份有限公司
申请人地址 ：
湖北省武汉市东湖新技术开发区高新大道999号未来科技大厦C3栋16-19层
代理机构 ：
深圳市六加知识产权代理有限公司
代理人 ：
向彬
优先权 ：
CN202111638140.8
主分类号 ：
G06F8/30
IPC分类号 ：
G06F8/30 G06F16/25 G06F16/901
IPC结构图谱
G
G部——物理
G06
计算；推算或计数
G06F
电数字数据处理
G06F8/00
软件工程设计
G06F8/30
创建或生成源代码
法律状态
2022-05-10 ：
实质审查的生效
IPC(主分类) : G06F 8/30
申请日 : 20211229
申请日 : 20211229
2022-04-22 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
