Data processing apparatus, distributed processing system, data processing method and data processing program
First Claim
Patent Images
1. A distributed processing system, comprising:
- a plurality of data processing apparatuses;
a distributed processing management apparatus, connected to the plurality of data processing apparatuses via a network, which manages the plurality of data processing apparatuses in a distributed processing of an application by the plurality of data processing apparatuses,the distributed processing management apparatus including;
a processing capacity information acquiring unit which acquires, from the plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via the network;
an application information acquiring unit which acquires information on an application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks;
a task distributing unit which determines which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired by the processing capacity information acquiring unit;
a task transmitting unit which transmits tasks to a data processing apparatus determined by the task distributing unit; and
a task information conveying unit which conveys information concerning a source apparatus of input data required by the respective task to the data processing apparatus executing the respective task, andthe data processing apparatus including;
a task acquiring unit which acquires the task;
a task executing unit which executes the task;
a task information acquiring unit which acquires information concerning a source apparatus of data required by the task;
a communication task generator which generates a send task to make the source apparatus transmit data required by the task to the data processing apparatus, and transmits the send task to the source apparatus, when the source apparatus is another data processing apparatus, which is different from the data processing apparatus, connected to the data processing apparatus via the network; and
a send task executing unit which executes, if a send task is acquired from an apparatus executing a subsequent task, the send task and transmits the data required by the subsequent task to the apparatus executing the subsequent task.
6 Assignments
0 Petitions
Accused Products
Abstract
A terminal includes a task information acquiring unit which acquires information on a task of data processing, and a communication task generator which generates a send task to allow a source apparatus of data required by the task to transmit the data required by the task to an apparatus executing the task and which transmits the send task to the source apparatus, when the source apparatus is another apparatus, which is different from the apparatus executing the task and which is connected to the apparatus executing the task via a network.
-
Citations
15 Claims
-
1. A distributed processing system, comprising:
-
a plurality of data processing apparatuses; a distributed processing management apparatus, connected to the plurality of data processing apparatuses via a network, which manages the plurality of data processing apparatuses in a distributed processing of an application by the plurality of data processing apparatuses, the distributed processing management apparatus including; a processing capacity information acquiring unit which acquires, from the plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via the network; an application information acquiring unit which acquires information on an application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks; a task distributing unit which determines which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired by the processing capacity information acquiring unit; a task transmitting unit which transmits tasks to a data processing apparatus determined by the task distributing unit; and a task information conveying unit which conveys information concerning a source apparatus of input data required by the respective task to the data processing apparatus executing the respective task, and the data processing apparatus including; a task acquiring unit which acquires the task; a task executing unit which executes the task; a task information acquiring unit which acquires information concerning a source apparatus of data required by the task; a communication task generator which generates a send task to make the source apparatus transmit data required by the task to the data processing apparatus, and transmits the send task to the source apparatus, when the source apparatus is another data processing apparatus, which is different from the data processing apparatus, connected to the data processing apparatus via the network; and a send task executing unit which executes, if a send task is acquired from an apparatus executing a subsequent task, the send task and transmits the data required by the subsequent task to the apparatus executing the subsequent task. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A distributed processing system, comprising:
-
a plurality of data processing apparatuses; a distributed processing management apparatus, connected to the plurality of data processing apparatuses via a network, which manages the plurality of data processing apparatuses in a distributed processing of an application by the plurality of data processing apparatuses, the distributed processing management apparatus including; a processing capacity information acquiring unit which acquires, from the plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via the network; an application information acquiring unit which acquires information on an application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks; a task distributing unit which determines which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired by the processing capacity information acquiring unit; a task transmitting unit which transmits tasks to a data processing apparatus determined by the task distributing unit; and a communication task generator which generates a send task to make a source apparatus of data required by the task transmit the data required by the task to an apparatus executing the task, and transmits the send task to the source apparatus, when the source apparatus is another apparatus, which is different from the apparatus executing the task, connected to the apparatus executing the task via a network, and the data processing apparatus including; a task acquiring unit which acquires the task; a task executing unit which executes the task; and a send task executing unit which executes, if a send task is acquired from the distributed processing management apparatus, the send task and transmits the data required by a subsequent task to the apparatus executing the subsequent task.
-
-
13. A data processing method, comprising:
-
acquiring, from a plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via a network, when a distributed processing of an application is performed by the plurality of data processing apparatuses; acquiring information on the application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks; determining which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired; transmitting tasks to a data processing apparatus determined; and generating a send task to make a source apparatus of data required by the task transmit the data required by the task to an apparatus executing the task and transmitting the send task to the source apparatus, when the source apparatus is another apparatus, which is different from the apparatus executing the task, connected to the apparatus executing the task via a network.
-
-
14. A computer program product for processing data, embedded on a non-transitory computer-readable recording medium, the product comprising:
-
a first acquiring module which acquires, from a plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via a network, when a distributed processing of an application is performed by the plurality of data processing apparatuses; a second acquiring module which acquires information on the application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks; a determining module which determines which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired; a transmitting module which transmits tasks to a data processing apparatus determined; and a generating module which generates a send task to make a source apparatus of data required by the task transmit the data required by the task to an apparatus executing the task, and transmits the send task to the source apparatus, when the source apparatus is another apparatus, which is different from the apparatus executing the task, connected to the apparatus executing the task via a network.
-
-
15. A distributed processing management apparatus, comprising:
-
a processing capacity information acquiring unit which acquires, from a plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via a network, when a distributed processing of an application is performed by the plurality of data processing apparatuses; an application information acquiring unit which acquires information on the application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks; a task distributing unit which determines which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired; a task transmitting unit which transmits the task to the data processing apparatus determined; and a communication task generator which generates a send task to make a source apparatus of data required by the task transmit the data required by the task to an apparatus executing the task, and transmits the send task to the source apparatus, when the source apparatus is another apparatus, which is different from the apparatus executing the task, connected to the apparatus executing the task via a network.
-
Specification