一种Flink框架运行ETL的流程方法和装置
实质审查的生效
摘要
本发明专利提供一种Flink框架运行ETL的流程方法和装置。操作算子可以直接使用Flink的Connector，比如kafka connector，或者实现自定义的SourceFunction、ProcessFunction运行部分ETL组件构成的DAG图。只要是ETL内置支持的数据处理，可以直接发布到Flink框架执行，不再需要手工编写flink算子代码，避免了代码冗余、维护繁杂以及数据处理的不稳定性；通过设置算子的并行度，可以极大提高ETL流程并发处理能力；通过Flink流式处理的有状态计算、故障恢复、容错能力，可以保障ETL流程运行的稳定可靠性。
基本信息
专利标题 ：
一种Flink框架运行ETL的流程方法和装置
专利标题（英）：
暂无
公开（公告）号 ：
CN114385137A
申请号 ：
CN202111639178.7
公开（公告）日 ：
2022-04-22
申请日 ：
2021-12-29
授权号 ：
暂无
授权日 ：
暂无
发明人 ：
高东升梅纲吴鑫胡高坤付晨玺
申请人 ：
武汉达梦数据库股份有限公司
申请人地址 ：
湖北省武汉市东湖新技术开发区高新大道999号未来科技大厦C3栋16-19层
代理机构 ：
深圳市六加知识产权代理有限公司
代理人 ：
向彬
优先权 ：
CN202111639178.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文件可下载
