System and method for task execution in data processing
AssigneeProfoundis Labs Pvt Ltd
InventorANOOP THOMAS MATHEW
Life of this patent
Estimating the term…
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.
Claims15
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.
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.
Dependencies are inferred from the claim text.