Analysis system and method for analyzing continuous queries for data streams

• US 8,346,511 B2
• Filed: 01/29/2010
• Issued: 01/01/2013
• Est. Priority Date: 01/21/2010
• Status: Active Grant

• Current Assignee: Software AG
• Original Assignee: Software AG
• Inventors: Schoning, Harald, Hafermann, Udo, Post, Ulrich
• Primary Examiner(s): Khuu, Cindy H
• Application Number:
  US12/656,465
• Publication Number:
  US 20110178775A1
• Time in Patent Office: 1,068 Days
• Field of Search: 702/190
• US Class Current: 702/190
• CPC Class Codes: G06F 11/28 by checking the correct order of processing G06F11/08 - G06F11/26 take precedence; monitoring patterns of pulse trains H03K5/19

Abstract

Certain example embodiments concern an analysis system for analyzing at least one continuous query for at least one input data stream. The at least one input data stream includes a sequence of events captured by at least one sensor. The debugging system includes an analyzer for executing the at least one continuous query and at least one modified continuous query on the at least one input data stream, for comparing at least one output data stream produced by the at least one continuous query with at least one second output data stream produced by the at least one modified continuous query, and for indicating at least one difference between the at least one output data stream and the at least one second output data stream. The analyzer synchronizes the execution of the at least one continuous query and the at least one modified continuous query.

Claims

1. An analysis system for analyzing at least one continuous query for at least one input data stream, wherein the at least one input data stream comprises a sequence of events captured by at least one sensor, and wherein the analysis system comprises:

an analyzer configured to execute the at least one continuous query and at least one modified continuous query on the at least one input data stream, compare at least one output data stream produced by the at least one continuous query with at least one second output data stream produced by the at least one modified continuous query, and indicate at least one difference between the at least one output data stream and the at least one second output data stream;

wherein the analyzer is further configured to synchronize the execution of the at least one continuous query and the at least one modified continuous query; and

wherein the system further comprises a stream logger configured to record the at least one output data stream into at least one recorded output data stream, wherein the analyzer is configured to select at least one event in the at least one recorded output data stream and to provide access to the corresponding at least one event in at least one recorded input data stream.

2. The analysis system of claim 1, wherein the analyzer is configured to let a user select at least one synchronization point within the at least one input data stream.

3. The analysis system of claim 1, wherein the analyzer is configured to analyze the at least one continuous query to determine at least one synchronization point within the at least one input data stream.

4. The analysis system of claim 1, wherein the analyzer is configured to execute the at least one modified continuous query and a copy of the at least one continuous query starting at the same event in the at least one input data stream.

5. The analysis system of claim 1, further comprising a graphical user interface (GUI) configured to display at least one operator graph of the at least one continuous query and at least one operator graph of the at least one modified continuous query, wherein the GUI is configured to highlight the at least one difference in the at least one operator graphs.

6. The analysis system of claim 1, wherein the analyzer is configured to re-execute the at least one continuous query on the at least one recorded input data stream starting at the selected at least one event and to log any intermediate results produced by the at least one continuous query.

7. An analysis system for analyzing at least one continuous query for at least one input data stream, wherein the at least one input data stream comprises a sequence of events captured by at least one sensor, and wherein the analysis system comprises;

an analyzer configured to execute the at least one continuous query and at least one modified continuous query on the at least one input data stream, compared at least one output data stream produced by the at least one continuous query with at least one second output data stream produced by the at least one modified continuous query, and indicate at least one difference between the at least one output data stream and the at least one second output data stream;

wherein the analyzer is further configured to synchronize the execution of the at least one continuous query and the at least one modified continuous query; and

wherein the analyzer is further configured to wait for the at least one modified continuous query to produce at least one event in the corresponding at least one second output data stream and to compare the at least one produced event with at least one corresponding event in the at least one output data stream produced by the at least one continuous query.

8. An analysis system for analyzing at least one continuous query for at least one input data stream, wherein the at least one input data stream comprises a sequence of events captured by at least one sensor, and wherein the analysis system comprises:

an analyzer configured to execute the at least one continuous query and at least one modified continuous query on the at least one input data stream, compare at least one output data stream produced by the at least one continuous query with at least one second output data stream produced by the at least one modified continuous query, and indicate at least one difference between the at least one output data stream and the at least one second output data stream;

wherein the analyzer is further configured to synchronize the execution of the at least one continuous query and the at least one modified continuous query; and

wherein the system further comprises a stream logger configured to record the at least one input data stream into at least one recorded input data stream, wherein the analyzer configured to execute the at least one modified continuous query on the at least one recorded input data stream followed by the at least one input data stream while it is captured by the at least one sensor.

9. A method for analyzing at least one continuous query for at least one input data stream, wherein the at least one input data stream comprises a sequence of events captured by at least one sensor, the method comprising:

executing, in connection with a processor of a computer, the at least one continuous query and at least one modified continuous query on the at least one input data stream, comparing at least one output data stream produced by the at least one continuous query with at least one second output data stream produced by the at least one modified continuous query and indicating at least one difference between the at least one output data stream and the at least one second output data stream;

synchronizing the execution of the at least one continuous query and the at least one modified continuous query;

recording, to a non-transitory computer storage medium, the at least one output data stream into at least one recorded output data stream;

enabling a user to select at least one event in the at least one recorded output data stream; and

providing access to the corresponding at least one event in at least one recorded input data stream.

10. The method of claim 9, wherein said synchronizing comprises analyzing the at least one continuous query to determine at least one synchronization point within the at least one input data stream.

11. The method of claim 9, further comprising executing the at least one modified continuous query and a copy of the at least one continuous query starting at the same event in the at least one input data stream.

12. A computer system including at least one processor and a computer program comprising a set of instructions that, when executed by the at least one processor, implement a method according to claim 9.

13. A method for analyzing at least one continuous query for at least one input data stream, wherein the at least one input data stream comprises a sequence of events captured by at least one sensor, the method comprising:

executing, in connection with a processor of a computer, the at least one continuous query and at least one modified continuous query on the at least one input data stream, comparing at least one output data stream produced by the at least one continuous query with at least one second output data stream produced by the at least one modified continuous query and indicating at least one difference between the at least one output data stream and the at least one second output data stream; and

synchronizing the execution of the at least one continuous query and the at least one modified continuous query, said synchronizing comprising waiting for the at least one modified continuous query to produce at least one event in the corresponding at least one second output data stream;

wherein said comparing includes comparing the at least one produced event with at least one corresponding event in the at least one output data stream produced by the at least one continuous query.