Method for generating workflow model and method and apparatus for executing workflow model

Patent metadata

Field	Value
Publication number	US-9798523-B2
Application number	US-201514954080-A
Country	US
Kind code	B2
Filing date	Nov 30, 2015
Priority date	Jun 11, 2015
Publication date	Oct 24, 2017
Grant date	Oct 24, 2017

Abstract

Disclosed are a method of modeling a workflow used in the field of big data and a method and apparatus for executing a workflow model. The method of executing the workflow model according to an embodiment of the present invention comprises receiving a Unified Modeling Language (UML)-based workflow model needing at least one data storage engine and at least one data processing engine, parsing the received workflow model to generate structured information, verifying the validity of the workflow model using the structured information, and transmitting jobs included in the workflow model to data processing engines corresponding to the jobs when it is determined that the workflow model is valid. Thus, developers can be allowed to easily acquire a workflow runnable on various data storage engines and various data processing engines.

First claim

What is claimed is:

1. A method of executing a workflow model, the method comprising:
generating a table including two partitions when a request to perform workflow modeling using Unified Modeling Language (UML) is received;
receiving a data processing engine name as a value of one of the partitions and receiving a data storage engine name as a value of the other of the partitions;
receiving at least one of a starting node, an ending node, an action node, and a control flow node of the workflow;
receiving resource information needed to execute jobs included in the workflow and an execution order of the jobs;
generating a workflow model conforming to an Object Management Group (OMG) XML Metadata Interchange (XMI) file format based on the input information;
receiving the generated workflow model needing at least one data storage engine and at least one data processing engine, the workflow model including the jobs;
parsing the received workflow model to generate structured information including information about a data processing engine and a data storage engine that are needed for each of the jobs;
verifying validity of the workflow model using the structured information; and
transmitting the jobs included in the workflow model to data processing engines corresponding to the jobs when it is determined that the workflow model is valid.

2. The method of claim 1 , wherein the workflow model is received in the form of an XML file.

3. The method of claim 2 , further comprising:
checking whether the workflow model conforms to the OMG XMI file format; and
discarding the XML file when the XML file does not conform to the OMG XMI file format.

4. The method of claim 1 , wherein the verifying of the validity of the workflow model comprises comparing the data processing engine name, the data storage engine name, and a resource allocation amount included in the generated structured information with predetermined information to check whether there is an error in logic of the workflow model.

5. The method of claim 1 , wherein the transmitting of the jobs to the data processing engines corresponding to the jobs comprises:
analyzing a flow of the jobs included in the workflow model and generating a queue using executable jobs; and
transmitting the jobs included in the queue to the data processing engines corresponding to the jobs.

6. The method of claim 5 , further comprising updating the queue using executable jobs among jobs remaining in the workflow model when the transmitted jobs are performed successfully.

7. An apparatus for executing a workflow model, the apparatus comprising:
a processor for executing a workflow engine, the workflow engine implemented in instructions executed by the processor and comprising:
a workflow model generator for:
generating a table including two partitions when a request to perform workflow modeling using Unified Modeling Language (UML) is received;
receiving a data processing engine name as a value of one of the partitions and receiving a data storage engine name as a value of the other of the partitions;
receiving at least one of a starting node, an ending node, an action node, and a control flow node of the workflow;
receiving resource information needed to execute jobs included in the workflow and an execution order of the jobs;
generating a workflow model conforming to an Object Management Group (OMG) XML Metadata Interchange (XMI) file format based on the input information;
a syntax checker configured to receive the generated workflow model needing at least one data storage engine and at least one data processing engine and check whether the received workflow model conforms to the OMG XMI file format, the workflow model including the jobs;
a parser configured to parse the workflow model to generate structured information including information about a data processing engine and a data storage engine that are needed for each of the jobs when the workflow model conforms to the OMG XMI file format;
a logic checker configured to verify validity of the workflow model using the structured information; and
a job submitter configured to transmit the jobs included in the workflow model to data processing engines corresponding to the jobs when the workflow model is valid.

8. The apparatus of claim 7 , wherein the workflow model is received in the form of an XML file.

9. The apparatus of claim 7 , wherein the syntax checker discards the workflow model when the workflow model does not conform to the OMG XMI file format.

10. The apparatus of claim 7 , wherein the logic checker compares the data processing engine name, the data storage engine name, and a resource allocation amount included in the generated structured information with predetermined information to check whether there is an error in logic of the workflow model.

11. The apparatus of claim 7 , further comprising a job scheduler configured to analyze a flow of the jobs included in the workflow model and generate a queue using executable jobs,
wherein the job submitter transmits the jobs included in the queue to the data processing engines corresponding to the jobs.

12. The apparatus of claim 11 , further comprising a job monitor configured to monitor whether the transmitted jobs are performed successfully,
wherein when the transmitted jobs are performed successfully, the job scheduler updates the queue using executable jobs among jobs remaining in the workflow model.

Assignees

• Electronics & Telecommunications Res Inst

Inventors

• Chau Nguyen Minh
• Won Hee-Sun

Classifications

• G06Q10/06

  Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling · CPC title

• G06F8/35 Primary

  model driven · CPC title

• G06F8/20 Primary

  Software design · CPC title