State initialization for continuous queries over archived views
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 identifying an archived view, the archived view identifying a join query between at least a first archived relation and a second archived relation associated with an application, the first archived relation comprising at least a first portion of historical data and incoming events related to an event stream of the application and the second archived relation comprising at least a second portion of the historical data and the incoming events related to the event stream;
generating a query plan for the continuous query;
identifying a view root operator in the archived view, the view root operator being identified as a join operator in the join query identified in the archived view;
determining that a set of one or more operators in the query plan comprises one or more query operators, the one or more query operators being identified as stateful query operators of the query plan that maintain state information related to the application;
identifying one or more of the stateful query operators in the query plan that topologically precede the view root operator;
constructing a set of one or more archiver queries corresponding to the one or more stateful query operators that topologically precede the view root operator;
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;
converting the result set of data records into a list of tuples for each of the one or more stateful query operators by;
determining a value of an ordering attribute in the combined archiver query, the value of the ordering attribute corresponding to a number of the one or more stateful query operators in the query plan; and
constructing the list of tuples for each of the one or more stateful query operators based at least in part on the value of the ordering attribute;
initializing a state of the one or more stateful query operators based at least in part on the list of tuples; 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 one or more stateful query operators.
1 Assignment
0 Petitions
Accused Products
Abstract
A method may include receiving a continuous query identified by an archived view. The method may also include creating the archived view, the archived view identified by a join query related to two or more archived relations associated with an application and/or generating a query plan for the continuous query. The method may also include identifying a view root operator in the archived view, the view root operator identified as a join operator in the archived view and/or identifying a query operator in the query plan that topologically precedes the view root operator. Further, the method may include constructing an archiver query for the identified query operator that topologically precedes the view root operator, executing the archiver query to obtain a result set of data records related to the application, and/or generating a snapshot output of one or more data values related to the application.
559 Citations
13 Claims
-
1. A computer-implemented method, comprising:
-
receiving, by a computer system configured to execute computer-executable instructions, a continuous query, the continuous query identifying an archived view, the archived view identifying a join query between at least a first archived relation and a second archived relation associated with an application, the first archived relation comprising at least a first portion of historical data and incoming events related to an event stream of the application and the second archived relation comprising at least a second portion of the historical data and the incoming events related to the event stream; generating a query plan for the continuous query; identifying a view root operator in the archived view, the view root operator being identified as a join operator in the join query identified in the archived view; determining that a set of one or more operators in the query plan comprises one or more query operators, the one or more query operators being identified as stateful query operators of the query plan that maintain state information related to the application; identifying one or more of the stateful query operators in the query plan that topologically precede the view root operator; constructing a set of one or more archiver queries corresponding to the one or more stateful query operators that topologically precede the view root operator; 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; converting the result set of data records into a list of tuples for each of the one or more stateful query operators by; determining a value of an ordering attribute in the combined archiver query, the value of the ordering attribute corresponding to a number of the one or more stateful query operators in the query plan; and constructing the list of tuples for each of the one or more stateful query operators based at least in part on the value of the ordering attribute; initializing a state of the one or more stateful query operators based at least in part on the list of tuples; 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 one or more stateful query operators. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A non-transitory 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 identifying an archived view, the archived view identifying a join query between-at least a first archived relation and a second archived relation associated with an application, the first archived relation comprising at least a first portion of historical data and incoming events related to an event stream of the application and the second archived relation comprising at least a second portion of the historical data and the incoming events related to the event stream; instructions that cause the one or more computer systems to identify a view root operator in the archived view, the view root operator being identified as a join operator in the join query identified in the archived view; instructions that cause the one or more processors to determine that a set of one or more operators in a query plan for the continuous query comprises one or more query operators, the one or more query operators being identified as stateful query operators of the query plan that maintain state information related to the application; instructions that cause the one or more computer systems to identify one or more of the stateful query operators in the query plan that topologically precede the view root operator; instructions that cause the one or more computer systems to construct a set of one or more archiver queries corresponding to the one or more stateful query operators that topologically precede the view root operator; 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 convert the result set of data records into a list of tuples for each of the one or more stateful query operators by; determining a value of an ordering attribute in the combined archiver query, the value of the ordering attribute corresponding to a number of the one or more stateful query operators in the query plan; and constructing the list of tuples for each of the one or more stateful query operators based at least in part on the value of the ordering attribute; instructions that cause the one or more computer systems to initialize a state of the one or more stateful query operators based at least in part on the list of tuples; and instructions that cause the one or more computer systems to generate 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 stateful query operators. - View Dependent Claims (8, 9, 10)
-
-
11. A system, comprising:
-
a memory storing a plurality of instructions; and a central processing unit configured to access the memory, wherein the central processing unit is further configured to execute the plurality of instructions to at least; receive a continuous query, the continuous query identifying an archived view, the archived view identifying a join query between-at least a first archived relation and a second archived relation associated with an application, the first archived relation comprising at least a first portion of historical data and incoming events related to an event stream of the application and the second archived relation comprising at least a second portion of the historical data and the incoming events related to the event stream; generate a query plan for the continuous query; identify a view root operator in the archived view, the view root operator being identified as a join operator in the join query identified in the archived view; determine that a set of one or more operators in the query plan comprises one or more query operators, the one or more query operators being identified as stateful query operators of the query plan maintain state information related to the application; identify one or more of the stateful query operators in the query plan that topologically precede the view root operator; construct a set of one or more archiver queries corresponding to the one or more stateful query operators that topologically precede the view root operator; 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; convert the result set of data records into a list of tuples for each of the one or more stateful query operators by; determining a value of an ordering attribute in the combined archiver query, the value of the ordering attribute corresponding to a number of the one or more stateful query operators in the query plan; and constructing the list of tuples for each of the one or more stateful query operators based at least in part on the value of the ordering attribute; initialize a state of the one or more stateful query operators based at least in part on the list of tuples; 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 one or more stateful query operators. - View Dependent Claims (12, 13)
-
Specification