公开(公告)号：CN118193565A

公开(公告)日：2024-06-14

申请号：CN202311844217.6

申请日：2023-12-28

Applicant: 中国兵器工业计算机应用技术研究所

Inventor： 孟英谦 ,  李旭光 ,  葛晋鹏 ,  李泽宇 ,  陈朔 ,  邬书豪 ,  随秋林 ,  张敏 ,  刘晓兰 ,  薛行 ,  王嘉岩 ,  李子行

IPC: G06F16/242 ,  G06F16/2455 ,  G06F16/25 ,  G06F16/245 ,  G06F9/50

Abstract: 本发明涉及一种分布式大数据计算引擎，包括：统一接口模块、分布式计算引擎模块和运算结果处理模块；统一接口模块用于接收计算任务，并基于计算任务的数据类型标识进行任务解析，以启动对应的计算引擎；分布式计算引擎模块包括流计算引擎、批计算引擎和批流一体计算引擎，分别用于读取并执行对应的计算任务；运算结果处理模块用于采集各个计算引擎的运行状态数据，进行运行状态监控并向客户端返回任务计算结果。本发明解决了现有技术中的大数据计算引擎在面对多种复杂的计算场景时，无法针对多类型的数据处理任务提供并行高效的实时计算，以进行实时快速响应的问题。