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