Granted Patent B2

US 12,443,605 · App. 17/518,447 · Granted Oct 14, 2025

Inventors: Unmesh Anil Deshmukh (Nagpur, IN); Anand Srinivasan (Bangalore, IN); Vikram Shukla (Fremont, CA)

Assignee: Oracle International Corporation

G06F16/24568G06F16/2308G06F16/24542G06F16/24544G06F16/951

Abstract

Claims (69)

1. A computer-implemented method, comprising:

identifying, by a computer system, a query plan for a continuous query, the query plan comprising one or more physical operators, the one or more physical operators comprising respective query operator flags;

sorting, by the computer system, the query plan;

identifying, by the computer system, at least one of the physical operators of the one or more physical operators in a traversal of the sorted query plan, wherein at least one of the respective query operator flags are set to false;

for each identified physical operator of the identified one or more physical operators in the traversal of the sorted query plan:

determining, by the computer system, whether state initialization has been performed on the identified physical operator; and

in accordance with a determination that no state initialization has been performed on the identified physical operator:

constructing, by the computer system, a query string for the identified physical operator;

setting, by the computer system, the query string as an output expression for the identified physical operator;

determining, by the computer system, whether the identified physical operator is stateful; and

in accordance with a determination that the identified physical operator is stateful;

marking, by the computer system, the identified physical operator comprising a respective query operator flag as a query operator at least in part by setting the respective query operator flag to true; and

in accordance with a determination that state initialization has been performed on the identified physical operator:

marking, by the computer system, the identified physical operator comprising a respective query operator flag as a query operator at least in part by setting the respective query operator flag to true.

2. The computer-implemented method of claim 1 , wherein the query plan comprises a physical query plan.

3. The computer-implemented method of claim 1 , wherein the query plan is sorted topologically.

4. The computer-implemented method of claim 1 , wherein the traversal of the sorted query plan is performed topologically.

5. The computer-implemented method of claim 1 , further comprising setting a second flag to false prior to identifying the one or more physical operators.

6. The computer-implemented method of claim 5 , wherein the second flag comprises a state initialization completion flag.

7. The computer-implemented method of claim 6 , further comprising:

setting, by the computer system, the second flag to true upon completing the traversal of the sorted query plan.

8. The computer-implemented method of claim 1 , wherein the output expression comprises an output structure query language (SQL) expression.

9. The computer-implemented method of claim 1 , further comprising constructing an archiver query for each identified physical operator that is marked as a query operator.

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

determining whether an archiver query can be generated for the identified physical operator; and

in accordance with a determination that the archiver query can be generated for the identified physical operator:

determining whether the identified physical operator can query the generated archiver query.

11. The computer-implemented method of claim 10 , wherein the query string is constructed for the identified physical operator in accordance with a determination that the identified physical operator can query the generated archiver query.

12. 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 instructions comprising:

identifying a query plan for a continuous query, the query plan comprising one or more physical operators, the one or more physical operators comprising respective query operator flags;

sorting the query plan;

identifying at least one of the physical operators of the one or more physical operators in a traversal of the sorted query plan, wherein at least one of the respective query operator flags are set to false; and

for each identified physical operator of the identified one or more physical operators in the traversal of the sorted query plan:

determining whether state initialization has been performed on the identified physical operator;

in accordance with a determination that no state initialization has been performed on the identified physical operator:

constructing a query string for the identified physical operator;

setting the query string as an output expression for the identified physical operator;

determining whether the identified physical operator is stateful; and in accordance with a determination that the identified physical operator is stateful:

marking the identified physical operator comprising a respective query operator flag as a query operator at least in part by setting the respective query operator flag to true; and

in accordance with a determination that state initialization has been performed on the identified physical operator:

marking, by the computer system, the identified physical operator comprising a respective query operator flag as a query operator at least in part by setting the respective query operator flag to true.

13. The non-transitory computer-readable storage medium of claim 12 , wherein the operations further comprise constructing an archiver query for each identified physical operator that is marked as a query operator.

14. The non-transitory computer-readable storage medium of claim 12 , wherein the operations further comprise:

determining whether an archiver query can be generated for the identified physical operator; and

in accordance with a determination that the archiver query can be generated for the identified physical operator:

determining whether the identified physical operator can query the generated archiver query.

15. The non-transitory computer-readable storage medium of claim 14 , wherein the query string is constructed for the identified physical operator in accordance with a determination that the identified physical operator can query the generated archiver query.

16. A system, comprising:

a memory storing a plurality of instructions; and

a processor configured to access the memory and execute the plurality of instructions to at least:

identify a query plan for a continuous query, the query plan comprising one or more physical operators, the one or more physical operators comprising respective query operator flags;

sort the query plan;

identify at least one physical operator of the one or more physical operators in a traversal of the sorted query plane wherein at least one of the respective query operator flags are set to false; and

for each identified physical operator of the identified one or more physical operators in the traversal of the sorted query plan:

determine whether state initialization has been performed on the identified physical operator;

in accordance with a determination that no state initialization has been performed on the identified physical operator:

construct a query string for the identified physical operator;

set the query string as an output expression for the identified physical operator;

determine whether the identified physical operator is stateful; and

in accordance with a determination that the identified physical operator is stateful:

mark the identified physical operator comprising a respective query operator flag as a query operator at least in part by setting the respective query operator flag to true

in accordance with a determination that state initialization has been performed on the identified physical operator:

mark, by the computer system, the identified physical operator comprising a respective query operator flag as a query operator at least in part by setting the respective query operator flag to true.

17. The system of claim 16 , wherein the processor is further configured to execute the plurality of instructions to at least construct an archiver query for each identified physical operator that is marked as a query operator.

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

determining whether an archiver query can be generated for the identified physical operator; and

in accordance with a determination that the archiver query can be generated for the identified physical operator:

determining whether the identified physical operator can query the generated archiver query.

19. The system of claim 18 , wherein the query string is constructed for the identified physical operator in accordance with a determination that the identified physical operator can query the generated archiver query.

Assignments (1)

Continuity (5)

References Cited (167)