- 专利标题: 一种流式运算系统、方法、可读介质和存储控制器
-
申请号: CN201810466470.5申请日: 2018-05-16
-
公开(公告)号: CN108845794B公开(公告)日: 2021-09-10
- 发明人: 宫若瑜 , 程林 , 杨培强
- 申请人: 浪潮软件科技有限公司
- 申请人地址: 山东省济南市高新区浪潮路1036号浪潮科技园
- 专利权人: 浪潮软件科技有限公司
- 当前专利权人: 浪潮软件科技有限公司
- 当前专利权人地址: 山东省济南市高新区浪潮路1036号浪潮科技园
- 代理机构: 济南信达专利事务所有限公司
- 代理商 李世喆
- 主分类号: G06F8/30
- IPC分类号: G06F8/30
摘要:
本发明提供了一种流式运算框架、方法、可读介质和存储控制器,该流式运算框架包括:订阅消息系统、流式数据处理系统和处理模块;其中,所述处理模块,用于将所述订阅消息系统与所述流式数据处理系统进行封装,生成数据转换工具;当接收到所述订阅消息系统发送的至少一个数据流时,利用所述数据转换工具对所述至少一个数据流的格式进行标准化处理,并将标准化处理后的所述至少一个数据流发送给所述流式数据处理系统;所述订阅消息系统,用于从外部的至少一个数据源中抽取至少一个数据流,并将所述至少一个数据流发送给所述处理模块;所述流式数据处理系统,用于对标准化处理后的所述至少一个数据流进行业务处理。本方案能提高数据处理效率。
公开/授权文献
- CN108845794A 一种流式运算框架、方法、可读介质和存储控制器 公开/授权日:2018-11-20