TRACKING LARGE NUMBERS OF MOVING OBJECTS IN AN EVENT PROCESSING SYSTEM
First Claim
1. A method comprising:
- receiving, by a computer system, an input event stream comprising a sequence of events, the sequence of events representing the movement of a plurality of objects; and
partitioning, by the computer system, the input event stream among a plurality of processing nodes to facilitate parallel tracking of the objects, wherein each processing node is configured to track objects in a predefined spatial region, and wherein the predefined spatial regions for at least two processing nodes in the plurality of processing nodes overlap.
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques for tracking large numbers of moving objects in an event processing system. In one set of embodiments, an input event stream can be received, where the events in the input event stream represent the movement of a plurality of geometries or objects. The input event stream can then be partitioned among a number of processing nodes of the event processing system, thereby enabling parallel processing of one or more continuous queries for tracking the objects. In a particular embodiment, the partitioning can be performed such that (1) each processing node is configured to track objects in a predefined spatial region, and (2) the spatial regions for at least two nodes overlap. This overlapping window enables a single node to find, e.g., all of the objects within a particular distance of a target object, even if the target object is in the process of moving from the region of that node to the overlapping region of another node.
-
Citations
19 Claims
-
1. A method comprising:
-
receiving, by a computer system, an input event stream comprising a sequence of events, the sequence of events representing the movement of a plurality of objects; and partitioning, by the computer system, the input event stream among a plurality of processing nodes to facilitate parallel tracking of the objects, wherein each processing node is configured to track objects in a predefined spatial region, and wherein the predefined spatial regions for at least two processing nodes in the plurality of processing nodes overlap. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. 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 the movement of a plurality of objects; and code that causes the processor to partition the input event stream among a plurality of processing nodes to facilitate parallel tracking of the objects, wherein each processing node is configured to track objects in a predefined spatial region, and wherein the predefined spatial regions for at least two processing nodes in the plurality of processing nodes overlap. - View Dependent Claims (13, 14)
-
-
15. 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 the movement of a plurality of objects; and partition the input event stream among the plurality of processing nodes to facilitate parallel tracking of the objects, wherein each processing node is configured to track objects in a predefined spatial region, and wherein the predefined spatial regions for at least two processing nodes in the plurality of processing nodes overlap. - View Dependent Claims (16, 17, 18, 19)
-
Specification