Join operations for continuous queries over archived views

• US 9,262,479 B2
• Filed: 09/25/2013
• Issued: 02/16/2016
• Est. Priority Date: 09/28/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Deshmukh, Unmesh Anil, Srinivasan, Anand, Shukla, Vikram, Kali, Prathab
• Primary Examiner(s): Truong, Dennis
• Application Number:
  US14/037,171
• Publication Number:
  US 20140095471A1
• Time in Patent Office: 874 Days
• Field of Search: 707/713, 707/661, 707/E17.017, 707/E17.054, 707/718, 707/737, 707/769, 707/774, 707/999.004
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2308 Concurrency control transaction processing G06F9/466
• CPC Class Codes: G06F 16/24542 Plan optimisation
• CPC Class Codes: G06F 16/24544 Join order optimisation
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/951 Indexing; Web crawling techniques

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.

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 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 concurrently executing as being the same type as the query operator identified in the query plan; and

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 continuous query.

14. The system of claim 12, wherein the processor is further configured to execute the plurality of instructions to at least initialize the state of the operator based at least in part on the result set of data records.

15. The system of claim 14, wherein the processor is further configured to execute the plurality of instructions to at least 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.