State initialization algorithm for continuous queries over archived relations
First Claim
1. A computer-implemented method, comprising:
- receiving, by a computer system configured to execute computer-executable instructions, a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application;
generating a physical query plan for the continuous query;
identifying a set of one or more query operators in the physical query plan;
constructing a set of one or more archiver queries corresponding to the set of one or more identified query operators based at least in part on the identifying;
combining the set of one or more archiver queries to generate a combined archiver query;
executing the combined archiver query to obtain a result set of data records related to the application;
initializing a state of the one or more identified query operators based at least in part on the result set of data records, the initializing comprising constructing a list of tuples for the one or more identified query operators from the result set of data records;
generating a snapshot output of one or more data values related to the application based at least in part on the state of the one or more identified query operators; and
processing incoming real-time events related to the application based at least in part on the snapshot output of the one or more data values.
1 Assignment
0 Petitions
Accused Products
Abstract
In some examples, a method may include receiving a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application. The method may also include generating a physical query plan for the continuous query. In some examples, the method may also include identifying a query operator in the physical query plan and/or constructing an archiver query for the identified query operator. In some aspects, the method may also include executing the archiver query to obtain a result set of data records related to the application and/or initializing a state of the query operator based at least in part on the result set of data records. Further, the method may also include generating a snapshot output of one or more data values related to the application based at least in part on the state of the identified query operator.
-
Citations
14 Claims
-
1. A computer-implemented method, comprising:
-
receiving, by a computer system configured to execute computer-executable instructions, a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application; generating a physical query plan for the continuous query; identifying a set of one or more query operators in the physical query plan; constructing a set of one or more archiver queries corresponding to the set of one or more identified query operators based at least in part on the identifying; combining the set of one or more archiver queries to generate a combined archiver query; executing the combined archiver query to obtain a result set of data records related to the application; initializing a state of the one or more identified query operators based at least in part on the result set of data records, the initializing comprising constructing a list of tuples for the one or more identified query operators from the result set of data records; generating a snapshot output of one or more data values related to the application based at least in part on the state of the one or more identified query operators; and processing incoming real-time events related to the application based at least in part on the snapshot output of the one or more data values. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A computer-readable storage medium storing computer-executable instructions that, when executed by one or more computer systems, configure the one or more computer systems to perform at least:
-
instructions that cause the one or more computer systems to receive a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application; instructions that cause the one or more computer systems to construct a set of one or more archiver queries for a set of one or more query operators identified in a physical query plan for the continuous query; instructions that cause the one or more computer systems to combine the set of one or more archiver queries to generate a combined archiver query; instructions that cause the one or more computer systems to execute the combined archiver query to obtain a result set of data records related to the application; instructions that cause the one or more computer systems to construct a list of tuples for the one or more identified query operators from the result set of data records; instructions that cause the one or more computer systems to initialize the state of the identified one or more query operators based at least on the list of tuples; instructions that cause the one or more computer systems to generate a snapshot output of the one or more data values related to the application based at least in part on the list of tuples; and instructions that cause the one or more computer systems to process incoming real-time events related to the application based at least in part on the snapshot output of the one or more data values. - View Dependent Claims (7, 8, 9, 10, 11)
-
-
12. A system, comprising:
-
a memory storing a plurality of instructions; and a processor configured to access the memory, wherein the processor is further configured to execute the plurality of instructions to at least; receive a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application; generate a physical query plan for the continuous query; identify a set of one or more query operators in the physical query plan; construct a set of one or more archiver queries corresponding to the set of one or more identified query operators based at least in part on the instructions to identify; combine the set of one or more archiver queries to generate a combined archiver query; execute the combined archiver query to obtain a result set of data records related to the application; construct a list of tuples for the one or more identified query operators from the result set of data records; initialize a state of the one or more identified query operators based at least in part on the list of tuples; generate a snapshot output of one or more data values related to the application based at least in part on the state of the list of tuples; and process incoming real-time events related to the application based at least in part on the snapshot output of the one or more data values. - View Dependent Claims (13, 14)
-
Specification