Processing program to rearrange order of task in stream processing

1. A method comprising:

by a processor coupled to a memory,

acquiring, from the memory, a plurality of patterns of a plurality of tasks to be candidates of an arrangement order of the plurality of tasks from upstream to downstream of a first stream in a case of executing the plurality of tasks using a stream processing format;

specifying, from the memory storing task information, for a pattern of the plurality of acquired patterns, an amount of data to be reintroduced to the first stream, through a second stream outside of the first stream, from one task of the plurality of tasks to another task of the plurality of tasks located upstream side of the first stream with respect to the one task; and

determining a first pattern, from among the plurality of acquired patterns, that indicates a rearranged order of a plurality of tasks from upstream to downstream of the first stream, based on the specified amount of data to be reintroduced for the first pattern through the second stream.

2. The information processing method according to claim 1 , the method further comprising:

causing a stream processing platform to execute the plurality of tasks, using the stream processing format, in a state of arranging the plurality of tasks from upstream to downstream of the stream according to the determined pattern.

3. The information processing method according to claim 1 , the method further comprising:

specifying, for a pattern of the plurality of acquired patterns, an amount of data to be transmitted from one task of the plurality of tasks to another task located downstream side of the stream with respect to the one task,

wherein the determining includes determining a second pattern that indicates a rearranged order of a plurality of tasks based on the specified amount of data to be reintroduced and the specified amount of data to be transmitted for the second pattern through the second stream.

4. The information processing method according to claim 3 , wherein the determining further includes

determining the second pattern that indicates the rearranged order of the plurality of tasks based on a coefficient that represents a magnitude of a cost in transmitting data to a task among the tasks in the first stream.

5. The information processing method according to claim 1 , wherein the determining further includes determining the first pattern that indicates the rearranged order of the plurality of tasks based on a coefficient that represents a magnitude of a cost in reintroducing data to a task among the tasks in the first stream.

6. The information processing method according to claim 1 , wherein the acquiring includes

selecting one task from the plurality of tasks, and acquiring a plurality of patterns to be candidates of the rearranged order of the plurality of tasks from upstream to downstream of the stream in a case of executing the plurality of tasks using the stream processing format, the plurality of patterns each of which has a different position of the one task.

7. The information processing method according to claim 6 , wherein the acquiring includes

selecting the one task that is other than a task selected in one period of past periods from the plurality of tasks.

8. The information processing method according to claim 7 , wherein the one period is a period from a time point selected a predetermined number of times before a present time point among a plurality of time points when selecting a task included in the plurality of tasks in the past to the present time point.

9. The information processing method according to claim 6 , wherein the acquiring includes

selecting the one task from the plurality of tasks in which at least either an amount of data to be transmitted to another task or an amount of data to be received from another task satisfies a predetermined condition.

10. The information processing method according to claim 6 , wherein the acquiring includes

selecting one task from the plurality of tasks in which at least either an amount of data to be reintroduced to another task or an amount of data to be reintroduced from another task satisfies a predetermined condition.

11. The information processing method according to claim 1 , wherein the determining includes,

in a case where the specified amount of data to be reintroduced from at least one task of the plurality of tasks to another task satisfies a condition, determining the first pattern that indicates the rearranged order of the plurality of tasks based on the specified amount of data that satisfies the condition, to be reintroduced for the first pattern.

12. The information processing method according to claim 1 , wherein the pattern is a pattern of arranging the plurality of tasks on a plurality of stages from upstream to downstream of the stream.

13. A non-transitory computer-readable storage medium having stored an information processing program causing a computer to perform a process comprising:

acquiring, from a memory, a plurality of patterns of a plurality of tasks to be candidates of an arrangement order of the plurality of tasks from upstream to downstream of a first stream in a case of executing the plurality of tasks using a stream processing format;

specifying, from the memory storing task information, for a pattern of the plurality of acquired patterns, an amount of data to be reintroduced to the first stream, through a second stream outside of the first stream, from one task of the plurality of tasks to another task of the plurality of tasks located upstream side of the first stream with respect to the one task; and

determining, from among the plurality of acquired patterns, a pattern that indicates a rearranged order of a plurality of tasks from upstream to downstream of the first stream, based on the specified amount of data to be reintroduced for the pattern through the second stream.