可装配的大数据流式计算引擎

Assemblable Big Data Flow Computing Engine

本方案涉及大数据技术领域一种流式数据计算引擎的实现方法和装置,包括:接收用户编辑请求,所述编辑请求中包括算子及其配置信息;根据所述算子及其配置信息提交给编译引擎,编译引擎通过编译识别所述算子及其配置信息,对所述的算子及其配置分配运行空间及监控设备,提交编译后的算子及其配置信息到计算引擎进行数值计算,并通过推送引擎将计算结果通知到最终用户。

This project involves the implementation method and device of a flow data computing engine in the field of big data technology,including:receiving user edit request,which includes operator and configuration information;described according to the operator and its configuration information to compile the engine,engine operator described by compiling recognition and its configuration,its configuration information to described by the operator operating space distribution and monitoring equipment,and its configuration information to submit the compiled operator calculation engine,numerical calculation,and the results to the end user via the push engine.