SYSTEM AND METHOD FOR TASK EXECUTION IN DATA PROCESSING
First Claim
1. A method for executing one or more tasks in data processing, the method being performed by one or more processors, the method comprising:
- receiving data from at least one channel from multiple channels;
generating the one or more tasks based on the data, wherein the data provides an input moment to the one or more tasks for generating a result;
selecting a task from the one or more tasks by a worker node from one or more worker nodes; and
executing the one or more tasks in a pipeline by the work node for generating a result.
1 Assignment
0 Petitions
Accused Products
Abstract
System and method for executing one or more tasks in data processing is disclosed. Data is received from at least one channel from multiple channels. The data is received in order to generate a corresponding result. A set of tasks is generated. The set of tasks is generated to process the data so received. The tasks receive the data as an input argument for generating the corresponding result. A worker node from a plurality of worker node is selected for executing the set of task in a pipeline. An idle worker node from the plurality of worker node is selected for executing the set of tasks. The set of task is executed by the selected worker nodes in order to generate the corresponding result. The results are stored for a predefined time in the system.
27 Citations
15 Claims
-
1. A method for executing one or more tasks in data processing, the method being performed by one or more processors, the method comprising:
-
receiving data from at least one channel from multiple channels; generating the one or more tasks based on the data, wherein the data provides an input moment to the one or more tasks for generating a result; selecting a task from the one or more tasks by a worker node from one or more worker nodes; and executing the one or more tasks in a pipeline by the work node for generating a result. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
-
9. A system for executing one or more tasks in data processing, the system comprising:
-
a processor; and a memory coupled to the processor, wherein the memory stores a plurality of modules to be executed by the processor, wherein the plurality of modules are configured to; receive data from at least one channel from multiple channels; generate the one or more tasks based on the data, wherein the data provides an input argument to the one or more tasks for generating a result; select a task from the one or more tasks by a worker node from one or more worker nodes; and execute the one or more tasks in a pipeline by the work node for generating a result. - View Dependent Claims (10, 11, 12, 13, 14, 15)
-
Specification