Join operations for continuous queries over archived views

Patent metadata

Field	Value
Publication number	US-9262479-B2
Application number	US-201314037171-A
Country	US
Kind code	B2
Filing date	Sep 25, 2013
Priority date	Sep 28, 2012
Publication date	Feb 16, 2016
Grant date	Feb 16, 2016

Abstract

A continuous query may be received, the continuous query being identified based at least in part on an archived view. The archived view may be created and/or identified based at least in part on a join query related to two or more archived relations associated with an application, at least one of the two or more archived relations being identified as a dimension relation. A query plan for the continuous query may be generated. A join operator in the query plan may be identified based at least in part on the dimension relation. A state of an operator corresponding to the dimension relation may be initialized. It may be identified if the state of the operator identifies an event that detects a change to the dimension relation. The continuous query may be re-started based at least in part on the event that detects the change to the dimension relation.

First claim

What is claimed is:

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 operation between a fact relation and a dimension relation;
generating a query plan for the continuous query;
initializing a state of an operator in the query plan corresponding to the dimension relation;
identifying if the state of the operator identifies an event that detects a change to the dimension relation;
re-starting the continuous query based at least in part on the event that detects the change to the dimension relation;
identifying a view root operator in the archived view;
constructing an archiver query for the operator, the operator topologically preceding the view root operator;
executing the archiver query to obtain a result set of data records related to an application; and
generating a snapshot output of one or more data values related to the application based at least in part on the result set of data records related to the application.

2. The computer-implemented method of claim 1 , further comprising initializing the state of the operator based at least in part on the result set of data records.

3. The computer-implemented method of claim 1 , further comprising generating the snapshot output of one or more data values related to the application based at least in part on the state of the operator.

4. The computer-implemented method of claim 1 , further comprising:
traversing the query plan in topological order to identify the view root operator, the view root operator being identified by an output operator to store event information related to the application;
inserting a buffer operator between the view root operator and the output operator in the query plan; and
storing the event information from the view root operator in the buffer operator.

5. The computer-implemented method of claim 4 , further comprising:
identifying a second query operator in a second continuous query concurrently executing as being the same type as the query operator identified in the query plan, the second continuous query being identified based at least in part on the archived view; and
generating a combined query plan based at least in part on the query operator identified in the query plan being the same type as the second query operator in the second continuous query.

6. 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 processors to receive a continuous query, the continuous query identifying an archived view, the archived view identifying a join operation between a fact relation and a dimension relation;
instructions that cause the one or more processors to generate a query plan for the continuous query;
instructions that cause the one or more processors to initialize a state of an operator in the query plan corresponding to the dimension relation;
instructions that cause the one or more processors to identify if the state of the operator identifies an event that detects a change to the dimension relation; and
instructions that cause the one or more processors to re-start the continuous query based at least in part on the event that detects the change to the dimension relation;
instructions that cause the one or more processors to identify a view root operator in the archived view;
instructions that cause the one or more processors to construct an archiver query for the operator, the operator topologically preceding the view root operator;
instructions that cause the one or more processors to execute the archiver query to obtain a result set of data records related to an application; and
instructions that cause the one or more processors to generate a snapshot output of one or more data values related to the application based at least in part on the result set of data records related to the application.

7. The non-transitory computer-readable storage medium of claim 6 , further comprising:
instructions that cause the one or more computer systems to traverse the query plan in topological order to identify the view root operator, the view root operator being identified by an output operator to store event information related to the application;
instructions that cause the one or more computer systems to insert a buffer operator between the view root operator and the output operator in the query plan; and
instructions that cause the one or more computer systems to store the event information from the view root operator in the buffer operator.

8. The non-transitory computer-readable storage medium of claim 6 , further comprising instructions that cause the one or more computer systems to generate the snapshot output of one or more data values related to the application based at least in part on the state of the operator.

9. The non-transitory computer-readable storage medium of claim 6 , further comprising:
instructions that cause the one or more computer systems to identify a second query operator in a second continuous query concurrently executing as being the same type as the query operator identified in the query plan, the second continuous query being identified based at least in part on the archived view; and
instructions that cause the one or more computer systems to generate a combined query plan based at least in part on the query operator identified in the query plan being the same type as the second query operator in the second continuous query.

10. The non-transitory computer-readable storage medium of claim 6 , further comprising instructions that cause the one or more computer systems to initialize the state of the operator based at least in part on the result set of data records.

11. The non-transitory computer-readable storage medium of claim 6 , further comprising instructions that cause the one or more computer systems to at least display a snapshot output of one or more data values related to the application based at least in part on the result set of data records related to the application.

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 identifying an archived view, the archived view identifying a join operation between a fact relation and a dimension relation;
generate a query plan for the continuous query;
initialize a state of an operator in the query plan corresponding to the dimension relation;
identify if the state of the operator identifies an event that detects a change to the dimension relation; and
re-start the continuous query based at least in part on the event that detects the change to the dimension relation;
identify a view root operator in the archived view;
construct an archiver query for the operator, the operator topologically preceding the view root operator;
execute the archiver query to obtain a result set of data records related to an application; and
generate a snapshot output of one or more data values related to the application based at least in part on the result set of data records related to the application.

13. The system of claim 12 , wherein the processor is further configured to execute the plurality of instructions to at least:
identify a second query operator in a continuous query concu

Assignees

• Oracle Int Corp

Inventors

• Deshmukh Unmesh Anil
• Srinivasan Anand
• Shukla Vikram
• Kali Prathab

Classifications

• G06F17/30463

  Physics · mapped topic

• G06F17/30516 Primary

  Physics · mapped topic

• G06F17/30466

  Physics · mapped topic

• G06F16/24542

  Plan optimisation · CPC title

• G06F16/24544

  Join order optimisation · CPC title