Complex event distributing apparatus, complex event distributing method, and complex event distributing program

A complex event distributing method that is a control method executed by a computer, the method comprising:

• calculating correlations between complex event processing processes executed on information processing apparatuses to detect events from a stream based on condition expressions each identifying an event;
• obtaining a load status of each of the information processing apparatuses;
• detecting an information processing apparatus having a processing load exceeding a predetermined level based on the load status thus obtained;
• and
• distributing the complex event processing processes to the information processing apparatuses based on the correlations between the complex event processing processes thus calculated when an information processing apparatus is detected to have a processing load exceeding the predetermined level.

A non-transitory computer-readable medium storing a program for processing a complex event distributing, the program causing a computer to execute:

• calculating correlations between complex event processing processes executed on information processing apparatuses to detect events from a stream based on condition expressions each identifying an event;
• obtaining a load status of each of the information processing apparatuses;
• detecting an information processing apparatus having a processing load exceeding a predetermined level based on the load status thus obtained;
• and
• distributing the complex event processing processes to the information processing apparatuses based on the correlations between the complex event processing processes thus calculated when an information processing apparatus is detected to have a processing load exceeding the predetermined level.

A complex event distributing apparatus comprising:

• a processor;
• and
• a memory, wherein the processor executes:
• calculating correlations between complex event processing processes executed on information processing apparatuses to detect events from a stream based on condition expressions each identifying an event;
• obtaining a load status of each of the information processing apparatuses;
• detecting an information processing apparatus having a processing load exceeding a predetermined level based on the load status thus obtained;
• and
• distributing the complex event processing processes to the information processing apparatuses based on the correlations between the complex event processing processes thus calculated when an information processing apparatus is detected to have a processing load exceeding the predetermined level.