基于流系统的流过程定义装置和流过程定义方法

摘要

本发明实施例提供了一种基于流系统的流过程定义装置及流过程定义方法，该流过程定义装置包括：算子模板配置单元，用于将用户自定义算子的可配置项和非可配置项分别设定为算子参数和算子模板文件；算子库，用于存储用户自定义算子的算子模板文件和公共算子；模板适配器，用于对应用描述文件进行解析以获取至少一个算子描述符，根据第一算子描述符中携带的算子标识从算子库中提取中第一算子描述符对应的算子模板文件，根据第一算子描述符对应的算子模板文件和第一算子描述符中携带的算子参数生成第一算子描述符对应的算子源码文件；编译器，用于对该应用描述文件中所有算子描述符生成的算子源码文件进行编译得到该应用描述文件的算子机器码文件。

主权项

一种基于流系统的流过程定义装置，其特征在于，包括：算子模板配置单元、算子库、模板适配器和编译器，其中，算子模板配置单元，用于在流系统中将用户自定义算子的可配置项设定为算子参数，将所述用户自定义算子的非可配置项设定为算子模板文件，并将所述算子模板文件存储于所述算子库中；算子库，用于存储所述流系统中的公共算子和所述流系统中用户自定义算子的算子模板文件；模板适配器，用于对应用描述文件进行解析以获取所述应用描述文件的至少一个算子描述符，其中，所述应用描述文件用于对业务应用在所述流系统的流过程进行描述定义，所述算子描述符用于对所述业务应用的一个算子进行描述定义，所述算子描述符携带所述算子的算子标识和算子参数，所述算子的算子参数能够表示所述算子与所述业务应用中其它算子之间的逻辑关系；所述模板适配器还用于当所述至少一个算子描述符中的第一算子描述符的算子标识为用户自定义算子时，根据所述第一算子描述符中携带的算子标识从所述算子库中提取中所述第一算子描述符对应的算子模板文件，根据所述第一算子描述符对应的算子模板文件和所述第一算子描述符中携带的算子参数生成所述第一算子描述符对应的算子源码文件；编译器，用于对所述应用描述文件中所有算子描述符生成的算子源码文件进行编译得到所述应用描述文件的算子机器码文件，所述应用描述文件的算子机器码文件能够被所述流系统部署形成所述业务应用的流过程。