US 9,811,378 B1
Information processing device, complex event processing method, and computer readable storage medium
Kenji Kobayashi, Kawasaki (JP); and Masazumi Matsubara, Machida (JP)
Assigned to FUJITSU LIMITED, Kawasaki (JP)
Filed by FUJITSU LIMITED, Kawasaki-shi, Kanagawa (JP)
Filed on Apr. 26, 2017, as Appl. No. 15/497,564.
Claims priority of application No. 2016-089486 (JP), filed on Apr. 27, 2016.
Int. Cl. G06F 9/48 (2006.01); G06F 9/50 (2006.01)
CPC G06F 9/4881 (2013.01) [G06F 9/5027 (2013.01)] 14 Claims
OG exemplary drawing
 
1. A computer-implemented method:
the computer-implemented method to process a plurality of input events in parallel among a plurality of computers comprising:
receiving the plurality of input events by the plurality of computers, the plurality of computers having a plurality of parallelization window lengths specifying an allocation amount available to receive the plurality of input events; and
processing the plurality of input events, the processing includes:
when a processing computer of the plurality of computers has received a number of input events corresponding to a parallelization window length of the processing computer:
obtaining a state of each of the plurality of computers, wherein the state indicating a window length remainder of each of the plurality of computers;
in response to the obtaining the state of the each of the plurality of computers, calculating a whole window length remainder based on the state of each of the plurality of computers; and
in response to the calculating the whole window length remainder based on the state of each of the plurality of computers, updating the parallelization window length of at least one of the plurality of computers based on the whole window length remainder.