OPTIMIZING PERFORMANCE IN CEP SYSTEMS VIA CPU AFFINITY
First Claim
1. A method for optimizing performance in a complex event stream (CEP) system, the method comprising:
- obtaining information about a plurality of CEP threads;
determining nearness among the plurality of CEP threads, wherein nearness between a first and a second CEP thread indicates how much interaction is expected to occur between the first and second CEP thread;
organizing the plurality of CEP threads into a plurality of CEP thread groups, based on the determined nearness; and
assigning each of the plurality of CEP thread groups to a different processing node, each processing node having one or more processors and a memory.
1 Assignment
0 Petitions
Accused Products
Abstract
In an example embodiment, performance is optimized in a complex event stream (CEP) system. Information about a plurality of CEP threads is obtained. Then nearness among the plurality of CEP threads is determined, wherein nearness between a first and a second CEP thread indicates how much interaction is expected to occur between the first and second CEP thread. Based on the determined nearness, the plurality of CEP threads are organized into a plurality of CEP thread groups. Then, each of the plurality of CEP thread groups are assigned to a different processing node, with each processing node having one or more processors and a memory.
-
Citations
20 Claims
-
1. A method for optimizing performance in a complex event stream (CEP) system, the method comprising:
-
obtaining information about a plurality of CEP threads; determining nearness among the plurality of CEP threads, wherein nearness between a first and a second CEP thread indicates how much interaction is expected to occur between the first and second CEP thread; organizing the plurality of CEP threads into a plurality of CEP thread groups, based on the determined nearness; and assigning each of the plurality of CEP thread groups to a different processing node, each processing node having one or more processors and a memory. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 10, 11, 12)
-
-
9. An apparatus comprising:
an event stream processing engine comprising; an affinity analyzer executable by a processor and configured to; obtain information about a plurality of CEP threads; determine nearness among the plurality of CEP threads, wherein nearness between a first and a second CEP thread indicates how much interaction is expected to occur between the first and second CEP thread; organize the plurality of CEP threads into a plurality of CEP thread groups, based on the determined nearness; and assign each of the plurality of CEP thread groups to a different processing node, each processing node having one or more processors and a memory.
-
13. A non-transitory machine-readable storage medium comprising instructions, which when implemented by one or more machines, cause the one or more machines to perform operations for optimizing performance in a complex event stream (CEP) system, the operations comprising:
-
obtaining information about a plurality of CEP threads; determining nearness among the plurality of CEP threads, wherein nearness between a first and a second CEP thread indicates how much interaction is expected to occur between the first and second CEP thread; organizing the plurality of CEP threads into a plurality of CEP thread groups, based on the determined nearness; and assigning each of the plurality of CEP thread groups to a different processing node, each processing node having one or more processors and a memory. - View Dependent Claims (14, 15, 16, 17, 18, 19, 20)
-
Specification