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 query operator in the physical query plan;
constructing an archiver query for the identified query operator;
executing the archiver query to obtain a result set of data records related to the application;
initializing a state of the query operator based at least in part on the result set of data records; and
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.
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
20 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 query operator in the physical query plan; constructing an archiver query for the identified query operator; executing the archiver query to obtain a result set of data records related to the application; initializing a state of the query operator based at least in part on the result set of data records; and 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. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. 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 an archiver query for a query operator identified in a physical query plan for the continuous query; instructions that cause the one or more computer systems to execute the 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 identified query operator from the result set of data records; instructions that cause the one or more computer systems to initialize the state of the identified query operator based at least on the list oftuples; and 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. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. 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 query operator in the physical query plan; construct an archiver query for the one identified query operator; execute the archiver query to obtain a result set of data records related to the application; initialize a state of the query operator based at least in part on the result set of data records; and generate 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. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification