Implementing event processors
First Claim
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 Assignments
0 Petitions
Accused Products
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.
-
Citations
18 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 - View Dependent Claims (2, 3, 4, 5, 6)
-
-
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 - View Dependent Claims (8, 9, 10, 11, 12)
- representing a CQL table as a SQL table;
-
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 - View Dependent Claims (14, 15, 16, 17, 18)
-
Specification