| CPC G06F 9/4881 (2013.01) [G06F 9/3836 (2013.01)] | 6 Claims |
|
6. A data stream processing method implemented by a computer configured to perform stream processing on a data stream, the stream processing including a task execution process and an external instruction process, the data processing method comprising:
in the external instruction process,
making an access to another information processing system instead of the task execution process, and receiving, from the another information processing system, an access result for the access, the access result including a response dataset;
in the task execution process,
in response to receiving, as a part of the data stream, a first sensor dataset containing information on an event measured by a first sensor, starting to execute a first task on the received first sensor dataset;
when execution of the first task on the first sensor dataset involves execution of a first process that requests the access to the another information processing system to obtain the response dataset, cancelling the execution of the first task on the first sensor dataset, and causing the external instruction process to make the access to the another information processing system for the first process;
in response to receiving, as a part of the data stream, a second sensor dataset containing information on an event measured by a second sensor, starting to execute the first task on the received second sensor dataset;
continuing the execution of the first task on the second sensor dataset when the execution of the first task on the second sensor dataset does not involve execution of the first process; and
when the external instruction process receives the access result for the access without re-executing the access to the another information processing system, re-executing the first task on the first sensor dataset after the execution of the first task on the second sensor dataset is completed, wherein
the re-executing of the first task on the first sensor dataset includes re-executing the first task including a process having been completed before the cancelling the execution of the first task on the first sensor dataset,
in the re-executing of the first task, performing the first process without re-executing the access to another information processing system, by using the response dataset included in the access result already received from the another information processing system by the external instruction process.
|