OPERATOR SHARING FOR CONTINUOUS QUERIES OVER ARCHIVED RELATIONS

• US 20140095447A1
• Filed: 09/25/2013
• Published: 04/03/2014
• 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
• Granted Patent: US 11,288,277 B2
• Time in Patent Office: Days
• US Class Current: 707/661
• 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 identified by an archived relation of an application may be received. A physical query plan may be generated for the continuous query and/or a child operator plan may be identified. A buffer operator may be inserted between the child operator and its parent operator and/or the event information from the child operator may be stored in the buffer operator. A query operator may be identified in the physical query plan. It may be determined that the query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing. Further, a combined query plan may be generated based at least in part on the query operator identified in the physical query plan being the same type as the second query operator in the second continuous query.

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 child operator related to a parent operator in the physical query plan, the child operator being identified by the parent operator to store event information related to the application;

inserting a buffer operator between the identified child operator and the parent operator in the physical query plan;

storing the event information from the child operator in the buffer operator;

identifying a query operator in the physical query plan, the query operator being identified based at least in part on the buffer operator;

determining, based at least in part on the buffer operator, that the query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing; and

generating a combined query plan based at least in part on the query operator identified in the physical query plan being the same type as the second query operator in the second continuous query.

2. The computer-implemented method of claim 1, further comprising:

constructing an archiver query for the identified query operator; and

executing the archiver query to obtain a result set of data records related to the application.

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

4. The computer-implemented method of claim 3, further comprising 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.

5. The computer-implemented method of claim 2, further comprising initializing the state of the identified query operator by constructing a list of tuples for the identified query operator from the result set of data records.

6. The computer-implemented method of claim 5, wherein at least one tuple in the list of tuples is constructed based at least in part on a subset of attributes in the result set of data records.

7. The computer-implemented method of claim 1, further comprising displaying a snapshot output of one or more data values related to the application to a user of the application via a display device.

8. The computer-implemented method of claim 7, further comprising 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.

9. 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 identify a child operator related to a parent operator in a physical query plan generated for the continuous query, the child operator being identified by the parent 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 identified child operator and the parent operator in the physical query plan;

instructions that cause the one or more computer systems to determine, based at least in part on the buffer operator, that a query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing; 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 physical query plan being the same type as the second query operator in the second continuous query.

10. The computer-readable storage medium of claim 9, further comprising instructions that cause the one or more computer systems to store the event information from the child operator in the buffer operator.

11. The computer-readable storage medium of claim 9, further comprising instructions that cause the one or more computer systems to identify the query operator in the physical query plan, the query operator being identified based at least in part on the buffer operator.

12. The computer-readable storage medium of claim 9, further comprising:

instructions that cause the one or more computer systems to construct an archiver query for the identified query operator; and

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.

13. The computer-readable storage medium of claim 12, further comprising instructions that cause the one or more computer systems to initialize a state of the identified query operator based at least in part on the result set of data records.

14. The computer-readable storage medium of claim 13, further comprising 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 identified query operator.

15. The computer-readable storage medium of claim 13, further comprising instructions that cause the one or more computer systems to initialize the state of the identified query operator by constructing a list of tuples for the identified query operator from the result set of data records.

16. 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 child operator related to a parent operator in the physical query plan, the child operator being identified by the parent operator to store event information related to the application;

insert a buffer operator between the identified child operator and the parent operator in the physical query plan;

store the event information from the child operator in the buffer operator;

identify a query operator in the physical query plan, the query operator being identified based at least in part on the buffer operator,

determine, based at least in part on the buffer operator, that the query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing; and

generate a combined query plan based at least in part on the query operator identified in the physical query plan being the same type as the second query operator in the second continuous query.

17. The system of claim 16, wherein the processor is further configured execute the plurality of instructions to at least:

construct an archiver query for the identified query operator; and

execute the archiver query to obtain a result set of data records related to the application.

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

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

20. The system of claim 16, wherein the processor is further configured to execute the plurality of instructions to at least display a snapshot output of the one or more data values related to the application to a user of the application via a display device.