Implementing event processors

• US 7,870,167 B2
• Filed: 11/09/2007
• Issued: 01/11/2011
• Est. Priority Date: 11/09/2007
• Status: Active Grant

• Current Assignee: Oracle America, Inc. (Oracle Corporation)
• Original Assignee: Oracle America, Inc. (Oracle Corporation)
• Inventors: Waldorf, Jerry, Lu, Yanbing
• Primary Examiner(s): Wu; Yicun
• Assistant Examiner(s): Mamillapalli; Pavan
• Application Number:
  US11/938,036
• Publication Number:
  US 20090125536A1
• Time in Patent Office: 1,159 Days
• Field of Search: 707/101, 707/803, 707/809
• US Class Current: 707/803
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries

Abstract

Novel techniques for implementing applications, such as event processors (“EPs”), designed in CQL are provided. Event processors, created as a network of CQL operators, can be implemented in SQL. Implementing an event processor in SQL allows the leveraging of significant industry knowledge and experience in research and development of SQL engines. A user can interact with an EP-generator application to design an event processor in CQL. The EP-generator application can implement the event processor by translating the CQL into SQL statements. Event-processing systems can execute the SQL implementation of the event processor in a first computing environment, such as an SQL database. In this manner, systems described herein can execute event processors defined as a network of CQL operators with high performance and scalability.

Claims

1. A method comprising:

representing at least one continuous-query-language (“

CQL”

) concept as a Structured Query Language (“

SQL”

) table, the at least one CQL concepts being a CQL table, a CQL stream, or a CQL relation;

translating a CQL operator into at least one SQL statement, wherein input to the CQL operator comprises at least one of the represented CQL concepts, wherein the CQL operator produces at least one of the represented CQL concepts as output, wherein the at least one SQL statement operates on at least one SQL table representing the input to the CQL operator, and wherein the at least one SQL statement produces at least one SQL table representing the output of the CQL operator; and

representing a CQL relation R having a schema K and a time-domain TD as a CQL table T according to the formula

2. The method of claim 1, comprising:

receiving, in a first computing environment, input to the CQL operator;

providing the received input to a SQL table in a second computing environment; and

executing, in the second computing environment, the at least one SQL statement.

3. The method of claim 2, wherein the executing step comprises:

producing an SQL table representing output of the CQL operator.

4. The method of claim 3, comprising:

retrieving, in the first computing environment, output of the CQL operator from the SQL table representing the output.

5. The method of claim 1, wherein representing a CQL table comprises:

representing a CQL table as a SQL table, the CQL table having a schema K and a defining function f, the SQL table having schema K and defining function f, and the SQL table containing f(s) rows of s for any s that is an element of K.

6. The method of claim 1, wherein representing a CQL stream comprises:

representing a CQL stream as a SQL table, the CQL stream having a schema K, a time-domain TD, and a defining function f, wherein the SQL table contains f(s, t) rows of (s, t) for any (s, t) that is an element of K×

TD.

7. Software stored in one or more computer-readable media, the software being able, when executed, to perform a method comprising:

representing a CQL table as a SQL table;

representing a CQL stream as a SQL table;

representing a CQL relation as a SQL table;

translating a CQL operator directly into at least one SQL statement,

wherein input to the CQL operator comprises a CQL table, a CQL stream, or a CQL relation, wherein the CQL operator produces output comprising a CQL table, a CQL stream, or a CQL relation, wherein the at least one SQL statement operates on at least one SQL table representing the input to the CQL operator, and wherein the at least one SQL statement produces at least on SQL table representing the output of the CQL operator; and

wherein representing a CQL relation comprises;

representing a CQL relation R having a schema K and a time-domain TD as a CQL table T according to the formula

8. The software of claim 7, wherein the method comprises:

receiving, in a first computing environment, input to the CQL operator;

providing the received input to a SQL table in a second computing environment; and

executing, in the second computing environment, the at least one SQL statement.

9. The software of claim 8, wherein the executing step comprises:

producing an SQL table representing output of the CQL operator.

10. The software of claim 9, wherein the method comprises:

retrieving, in the first computing environment, output of the CQL operator from the SQL table representing the output.

11. The software of claim 7, wherein representing a CQL table comprises:

representing a CQL table as a SQL table, the CQL table having a schema K and a defining function f, the SQL table having schema K and defining function f, and the SQL table containing f(s) rows of s for any s that is an element of K.

12. The software of claim 7, wherein representing a CQL stream comprises:

representing a CQL stream as a SQL table, the CQL stream having a schema K, a time-domain TD, and a defining function f, wherein the SQL table contains f(s, t) rows of (s, t) for any (s, t) that is an element of K×

TD.

13. An apparatus comprising:

a processor;

a memory unit that stores instructions associated with an application executable by the processor; and

an interconnect coupling the processor and the memory unit, enabling the apparatus to execute the application and perform a method comprising;

representing a CQL table as a SQL table;

representing a CQL stream as a SQL table;

representing a CQL relation as a SQL table;

translating a CQL operator into at least one SQL statement, wherein the translating is implemented using only SQL code, wherein input to the CQL operator comprises a CQL table, a CQL stream, or a CQL relation, wherein the CQL operator produces output comprising a CQL table, a CQL stream, or a CQL relation, wherein the at least one SQL statement operates on at least one SQL table representing the input to the CQL operator; and

wherein the at least one SQL statement produces at least on SQL table representing the output of the CQL operator; and

wherein representing a CQL relation comprises;

representing a CQL relation R having a schema K and a time-domain TD as a CQL table T according to the formula

14. The apparatus of claim 13, wherein the method comprises:

receiving, in a first computing environment, input to the CQL operator;

providing the received input to a SQL table in a second computing environment; and

executing, in the second computing environment, the at least one SQL statement.

15. The apparatus of claim 14, wherein the executing step comprises:

producing an SQL table representing output of the CQL operator.

16. The apparatus of claim 15, wherein the method comprises:

retrieving, in the first computing environment, output of the CQL operator from the SQL table representing the output.

17. The apparatus of claim 13, wherein representing a CQL table comprises:

representing a CQL table as a SQL table, the CQL table having a schema K and a defining function f, the SQL table having schema K and defining function f, and the SQL table containing f(s) rows of s for any s that is an element of K.

18. The apparatus of claim 13, wherein representing a CQL stream comprises:

representing a CQL stream as a SQL table, the CQL stream having a schema K, a time-domain TD, and a defining function f, wherein the SQL table contains f(s, t) rows of (s, t) for any (s, t) that is an element of K×

TD.