Task grouping in a distributed processing framework system and methods for implementing the same

Claim 1

A method for executing processing tasks in a distributed processing framework system including two or more processing resources, the method comprising: identifying a main task of a tasklist, with said main task having a plurality of main instructions, said main instructions being executable; identifying a subtask of the main task, with said sub-task having a plurality of sub-instructions, said sub-instructions being executable; allocating computing resources for the main task and the subtask before executing said plurality of main instructions and said plurality of sub-instructions, the allocated computing resource including a first computing system and a second computing system; and deploying the main task to the first computing system, a code of the main task being executed on the first computing system, the code of the main task having program instructions for requesting loading of a code for the subtask to the second computing system, the code forte subtask is in client-server communication with the code for the main task, such that the code for the main task receives processing results directly from the code for the subtask, wherein the first computing system is configured to be allocated to the main task continuously until each of the plurality of main instructions of the main task is executed or one of said plurality of main instructions of the main task causes an execution of the main task to discontinue, and further wherein the second computing system is configured to be allocated to the subtask continuously until each of the plurality of sub-instructions of the subtask is executed or an one of said plurality of sub-instructions of the subtask causes an execution of the subtask to discontinue.

Claim 2

A method for executing processing tasks in a distributed processing framework system including two or more processing resources, the method comprising: identifying a main task of a tasklist, with said main task having a plurality of main instructions, said main instructions being executable; identifying a subtask of the main task, with said sub-task having a plurality of sub-instructions, said sub-instructions being executable; allocating computing resources for the main task and the subtask before executing said plurality of main instructions and said plurality of sub-instructions, the allocated computing resource including a first computing system and a second computing system; and deploying the main task to the first computing system, a code of the main task being executed on the first computing system, the code of the main task having program instructions for requesting loading of a code for the subtask to the second computing system, the code forte subtask is in client-server communication with the code for the main task, such that the code for the main task receives processing results directly from the code for the subtask, wherein the first computing system is configured to be allocated to the main task continuously until each of the plurality of main instructions of the main task is executed or one of said plurality of main instructions of the main task causes an execution of the main task to discontinue, and further wherein the second computing system is configured to be allocated to the subtask continuously until each of the plurality of sub-instructions of the subtask is executed or an one of said plurality of sub-instructions of the subtask causes an execution of the subtask to discontinue.

Claim 6

A method for distributing an execution of a plurality of tasks within a tasklist by a system controller, the plurality of tasks configured to be processed by a plurality of processing resources in a distributed processing framework (DPF) system, the method comprising: loading the tasklist, the tasklist having a main task, including a plurality of main instructions, and a subtask including a plurality of sub-instructions; allocating processing resources to execute the main task and the subtask within the tasklist before executing said plurality of main instructions and said plurality of sub-instructions, the allocated processing resources including a first processing resource and a second processing resource, the first processing resource being separate for the second processing resource; deploying the main task to the first processing resource for execution; deploying the subtask to the second processing resource once a special request for the subtask is received from the main task; and enabling communication between the main task and the subtask, the communication configured to provide the main task with a result of a subtask execution, wherein the first processing resource is configured to be allocated to the main task continuously until each of said plurality of main instructions is executed or one of said plurality of main instructions causes an execution of the main task to discontinue, and further wherein the second computing resource is configured to be allocated to the subtask continuously until each of said plurality of sub instructions is executed or one of said plurality of sub instructions causes an execution of the subtask to discontinue.

Claim 7

A method for distributing an execution of a plurality of tasks within a tasklist by a system controller, the plurality of tasks configured to be processed by a plurality of processing resources in a distributed processing framework (DPF) system, the method comprising: loading the tasklist, the tasklist having a main task, including a plurality of main instructions, and a subtask including a plurality of sub-instructions; allocating processing resources to execute the main task and the subtask within the tasklist before executing said plurality of main instructions and said plurality of sub-instructions, the allocated processing resources including a first processing resource and a second processing resource, the first processing resource being separate for the second processing resource; deploying the main task to the first processing resource for execution; deploying the subtask to the second processing resource once a special request for the subtask is received from the main task; and enabling communication between the main task and the subtask, the communication configured to provide the main task with a result of a subtask execution, wherein the first processing resource is configured to be allocated to the main task continuously until each of said plurality of main instructions is executed or one of said plurality of main instructions causes an execution of the main task to discontinue, and further wherein the second computing resource is configured to be allocated to the subtask continuously until each of said plurality of sub instructions is executed or one of said plurality of sub instructions causes an execution of the subtask to discontinue.

Claim 16

A method for distributing an execution of a plurality of tasks by a system controller, the plurality of tasks configured to be processed by a plurality of processing resources in a distributed processing framework (DPF) system, the method comprising: loading the plurality of tasks, each of which includes instructions to be executed; allocating a separate processing resource to execute each task of the plurality of tasks before executing said instructions by searching a registry service for the processing resource having a plurality of attributes identical to a plurality of attributes of each task, and allocating each of the processing resources having a plurality of attributes identical to the plurality of each task to the execution of the task having the identical attributes; deploying each task to a respective processing resource at the same time; receiving a result task from each respective processing resource upon a conclusion of each task; and making the plurality of processing resources available for allocation of additional tasks upon receiving the result task from each of the plurality of processing resources.

Claim 17

A method for distributing an execution of a plurality of tasks by a system controller, the plurality of tasks configured to be processed by a plurality of processing resources in a distributed processing framework (DPF) system, the method comprising: loading the plurality of tasks, each of which includes instructions to be executed; allocating a separate processing resource to execute each task of the plurality of tasks before executing said instructions by searching a registry service for the processing resource having a plurality of attributes identical to a plurality of attributes of each task, and allocating each of the processing resources having a plurality of attributes identical to the plurality of each task to the execution of the task having the identical attributes; deploying each task to a respective processing resource at the same time; receiving a result task from each respective processing resource upon a conclusion of each task; and making the plurality of processing resources available for allocation of additional tasks upon receiving the result task from each of the plurality of processing resources.

Claim 20

A method for distributing an execution of a plurality of tasks by a system controller, the plurality of tasks configured to be processed by a plurality of processing resources in a distributed processing framework (DPF) system, the method comprising: loading the plurality of tasks, each of which includes instructions, to be executed; allocating a respective processing resource of the plurality of processing resources to execute each task of the plurality of tasks before executing said instructions by searching a registry service for the processing resource having a plurality of attributes identical to a plurality of attributes of each task, and allocating each of the processing resources having a plurality of attributes identical to the plurality of each task for the execution of the task having the identical attributes; deploying a first task of the plurality of tasks to a first processing resource of the plurality of processing resources; deploying a second task of the plurality of tasks to a second processing resource of the plurality of processing resources upon receiving a result of an execution of the first task; and making the plurality of processing resources available for allocation of additional tasks upon receiving a result of execution for each of the plurality of tasks, wherein each processing resource is configured to be allocated to a respective task continuously until each of the instructions associated with said respective task is executed or one of the instructions associated with said respective task causes an execution of the task to discontinue.

Claim 21

A method for distributing an execution of a plurality of tasks by a system controller, the plurality of tasks configured to be processed by a plurality of processing resources in a distributed processing framework (DPF) system, the method comprising: loading the plurality of tasks, each of which includes instructions, to be executed; allocating a respective processing resource of the plurality of processing resources to execute each task of the plurality of tasks before executing said instructions by searching a registry service for the processing resource having a plurality of attributes identical to a plurality of attributes of each task, and allocating each of the processing resources having a plurality of attributes identical to the plurality of each task for the execution of the task having the identical attributes; deploying a first task of the plurality of tasks to a first processing resource of the plurality of processing resources; deploying a second task of the plurality of tasks to a second processing resource of the plurality of processing resources upon receiving a result of an execution of the first task; and making the plurality of processing resources available for allocation of additional tasks upon receiving a result of execution for each of the plurality of tasks, wherein each processing resource is configured to be allocated to a respective task continuously until each of the instructions associated with said respective task is executed or one of the instructions associated with said respective task causes an execution of the task to discontinue.