Optimizing performance in CEP systems via CPU affinity

An apparatus comprising:

• an event stream processing engine comprising:
• an affinity analyzer executable by a processor and configured to:
• obtain, using one or more hardware processors, information about a plurality of CEP threads, wherein each CEP thread defines a sequence of computer operations that, when executed, cause information about one or more events corresponding to the CEP thread to be transmitted;
• determine, using the one or more hardware processors, 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, the nearness between the first and second threads being measured by calculating an actual amount of data transmitted between the first and second threads during a set period, wherein the higher the actual amount of data transmitted, the greater the nearness;
• organize the plurality of CEP threads into a plurality of CEP thread groups, each CEP thread group having CEP threads having high nearness with each other;
• and
• assign, using the one or more hardware processors, each of the plurality of CEP thread groups to a different processing node of a plurality of processing nodes, each processing node having one or more processors and a memory.

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, using one or more hardware processors, information about a plurality of CEP threads, wherein each CEP thread defines a sequence of computer operations that, when executed, cause information about one or more events corresponding to the CEP thread to be transmitted;
• determining, using the one or more hardware processors, 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, the nearness between the first and second threads being measured by calculating an actual amount of data transmitted between the first and second threads during a set period, wherein the higher the actual amount of data transmitted, the greater the nearness;
• organizing the plurality of CEP threads into a plurality of CEP thread groups, each CEP thread group having CEP threads having high nearness with each other;
• and
• assigning, using the one or more hardware processors, each of the plurality of CEP thread groups to a different processing node of a plurality of processing nodes, each processing node having one or more processors and a memory.