Systems and/or methods for appropriately handling events

• US 20120110599A1
• Filed: 11/03/2010
• Published: 05/03/2012
• Est. Priority Date: 11/03/2010
• Status: Active Grant

• Current Assignee: Software AG
• Original Assignee: Software AG
• Inventors: Schöning, Harald
• Granted Patent: US 9,542,448 B2
• Time in Patent Office: Days
• US Class Current: 719/318
• CPC Class Codes: G06F 16/2455 Query execution
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

Certain example embodiments described herein relate to techniques for the attachment of priorities and/or reaction time limits to various entities of a system such as, for example, events, event types, queries, etc. The system'"'"'s processing may be tailored behavior to match these boundary conditions while at the same time increasing (and sometimes even maximizing) the rate of events processed. Advantageously, the system may be made to adapt its behavior to the current situation, which is changeable and may even be changing quite frequently, e.g., as in connection with a potentially rapidly changing stream. Users may in certain example embodiments specify policies to control this adaptation in certain example embodiments and, thus, in certain example instances, events (including events of special interest) may be handled appropriately, even in response to changing conditions.

Claims

1. A method for handling a stream of events, the method comprising:

receiving the stream of events, at least some of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;

executing, via at least one processor of a computer system, predefined queries on the events;

for each said event having a maximum reaction time and/or priority attached thereto;

estimating whether the event can be processed within the attached boundary condition,

processing the predefined queries according to a first mode when the event can be processed within the attached boundary condition, and processing the predefined queries according to a second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do no consume events with attached boundary condition instead processing other queries; and

ending the second mode returning to processing according to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.

2. The method of claim 1, further comprising resuming at least temporarily queries and delivering all events when the second mode is ended.

3. The method of claim 1, further comprising temporarily storing in a data store any at least temporarily suspended queries.

4. The method of claim 1, further comprising, in the second mode, resuming any at least temporarily suspended queries associated with further received events that have attached boundary conditions.

5. The method of claim 4, further comprising applying real-time scheduling techniques to develop an improved processing plan during the second mode.

6. The method of claim 1, wherein the events are received via predefined channels on an event bus.

7. The method of claim 6, wherein at least one of said channels has a boundary condition associated therewith.

8. The method of claim 7, further comprising when an event has an attached boundary condition and the channel receiving the event also has an associated boundary condition, performing said estimating using the shorter reaction time and/or higher priority.

9. The method of claim 1, wherein each said event has an associated predefined event type.

10. The method of claim 9, wherein boundary conditions for events are at initially set by virtue of the event type.

11. The method of claim 10, wherein each said query includes a specification of any event types consumed, transformation specifications specifying how to compute any query outputs from any query inputs, and a definition of any output events with an explicit or implicit event type.

12. The method of claim 11, wherein the query further includes conditions or constraints any events it consumes.

13. The method of claim 1, wherein at least some of said events have a maximum reaction time and/or priority attached thereto indirectly by virtue of an assignment of the maximum reaction time and/or priority to one or more associated event types on which the events are based.

24. A non-transitory computer readable storage medium tangibly storing instructions that, when executed by a processor of a system, perform a method according to claim 1.

14. A method for configuring a system to handle a stream of events, the method comprising:

defining a plurality of event types;

storing said event types in an event type registry; and

enabling the system to execute in first and second modes, wherein;

the stream of events is received, at least some of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;

queries are executed, via at least one processor of the system, on the events;

for each said event having a maximum reaction time and/or priority attached thereto;

whether the event can be processed within the attached boundary condition is estimated,

the queries are processed according to the first mode when the event can be processed within the attached boundary condition, and

the queries are processed according to the second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do no consume events with attached boundary condition instead processing other queries; and

the second mode is ended and processing is returned to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.

15. The method of claim 14, wherein at least temporarily suspended queries are resumed and all events are delivered when the second mode is ended.

16. The method of claim 14, wherein any at least temporarily suspended queries associated with further received events that have attached boundary conditions are resumed in the second mode.

17. The method of claim 14, further comprising configuring channels on an event bus of the system, the events being receivable by the channels.

18. The method of claim 17, wherein at least one of said channels has a boundary condition associated therewith.

19. The method of claim 18, wherein when an event has an attached boundary condition and the channel receiving the event also has an associated boundary condition, said estimating is performed using the shorter reaction time and/or higher priority.

20. The method of claim 14, wherein each event is associated with exactly one event type.

21. The method of claim 14, further comprising defining said queries to include a specification of any event types consumed, transformation specifications specifying how to compute any query outputs from any query inputs, and a definition of any output events with an explicit or implicit event type.

22. The method of claim 21, wherein the query further includes conditions or constraints any events it consumes.

25. A system configured to generate and process a stream of events, comprising:

program logic for handling the stream of events according to the method of claim 14.

26. A non-transitory computer readable storage medium tangibly storing instructions that, when executed by a processor of a system, perform a method according to claim 14.

23. A system configured to generate and process a stream of events, comprising:

an event bus configured to receive the stream of events, at least some of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;

at least one processor configured to execute predefined queries on the events, the at least one processor being further configured to;

for each said event having a maximum reaction time and/or priority attached thereto;

estimate whether the event can be processed within the attached boundary condition,

process the predefined queries according to a first mode when the event can be processed within the attached boundary condition, and

process the predefined queries according to a second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do no consume events with attached boundary condition instead processing other queries; and

end the second mode return to processing according to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.