基于flink框架的ETL流程组件多个不同输出的处理方法...
实质审查的生效
摘要
本发明涉及数据处理技术领域，本发明提供基于flink框架的ETL流程组件多个不同输出的处理方法与装置，将ETL流程组件经过拆分重组，然后翻译转换成Flink的操作算子，在Flink操作算子方法中运行重组的ETL子流程，避免重复编写Flink算子中数据处理逻辑代码，避免重复实现数据拆分的逻辑代码；根据组件在流程中的特点，尽量在一个操作算子ProcessFunction运行重组后的组件集合，避免数据在多个操作算子拆分流转，从而减少线程切换、减少延迟并提高吞吐能力。
基本信息
专利标题 ：
基于flink框架的ETL流程组件多个不同输出的处理方法与装置
专利标题（英）：
暂无
公开（公告）号 ：
CN114385140A
申请号 ：
CN202111642588.7
公开（公告）日 ：
2022-04-22
申请日 ：
2021-12-29
授权号 ：
暂无
授权日 ：
暂无
发明人 ：
高东升梅纲吴鑫胡高坤付晨玺
申请人 ：
武汉达梦数据库股份有限公司
申请人地址 ：
湖北省武汉市东湖新技术开发区高新大道999号未来科技大厦C3栋16-19层
代理机构 ：
深圳市六加知识产权代理有限公司
代理人 ：
向彬
优先权 ：
CN202111642588.7
主分类号 ：
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文件可下载
