Tracking large numbers of moving objects in an event processing system

A non-transitory computer readable medium having stored thereon program code executable by a processor, the program code comprising:

• code that causes the processor to receive an input event stream comprising a sequence of events, the sequence of events representing movement of a plurality of objects, the input event stream including a first event of the sequence of events, and the first event being associated with a first object of the plurality of objects;
• code that causes the processor to partition the input event stream among a plurality of processing nodes to facilitate parallel tracking of the plurality of objects using a plurality of bit vectors that correspond to the plurality of processing nodes, each of the plurality of bit vectors comprising a plurality of bit values corresponding to the plurality of objects, and the code that causes the processor to partition the input event stream comprises, for each event in the sequence of events:
• code that causes the processor to determine using a first bit value of a first bit vector of the plurality of bit vectors that is associated with a first processing node of the plurality of processing nodes, that the first processing node is not currently tracking the first object of the plurality of objects, the first bit value being associated with the first object;
• code that causes the processor to change the first bit value from a first value to a second value that is different than the first value;
• and
• code that causes the processor to transmit a command to the first processing node for inserting the first event into a first spatial-region-representing relation that is operated upon by the first processing node.

An event processing system comprising:

• a load balancer node;
• and
• a plurality of processing nodes, wherein the load balancer node is configured to:
• receive an input event stream comprising a sequence of events, the sequence of events representing movement of a plurality of objects, the input event stream including a first event of the sequence of events, and the first event being associated with a first object of the plurality of objects;
• partition the input event stream among a plurality of processing nodes to facilitate parallel tracking of the plurality of objects using a plurality of bit vectors that correspond to the plurality of processing nodes, each of the plurality of bit vectors comprising a plurality of bit values corresponding to the plurality of objects, and the partitioning of the input event stream comprising, for each event in the sequence of events:
• determining, by the computer system using a first bit value of a first bit vector of the plurality of bit vectors that is associated with a first processing node of the plurality of processing nodes, that the first processing node is not currently tracking the first object of the plurality of objects, the first bit value being associated with the first object;
• changing, by the computer system, the first bit value from a first value to a second value that is different than the first value;
• and
• transmitting, by the computer system, a command to the first processing node for inserting the first event into a first spatial-region-representing relation that is operated upon by the first processing node.