Systems and Methods for Managing Queries

• US 20090228465A1
• Filed: 03/05/2009
• Published: 09/10/2009
• Est. Priority Date: 03/06/2008
• Status: Active Grant

• Current Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Original Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Inventors: Thombre, Neil, Li, Wing Hang, Conway, Neil, Krishnamurthy, Saileshwar
• Granted Patent: US 8,903,802 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24532 of parallel queries
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/2471 Distributed queries

Abstract

A streaming database management system may provide support for creating a new continuous query operator for on-the-fly addition of a new query, e.g., a new SQL query and/or new continuous query operator, into a shared continuous query plan. Alternatively, the streaming database management system may associate the new query on-the-fly with an existing continuous query operator, such as a relational operator and expression evaluator, to reuse the existing continuous query operator. In some embodiments, multiple operators are grouped for on-the-fly addition to the shared continuous query plan. Alternatively, the streaming database management system may identify a group of multiple operators in the shared continuous query plan for reuse by the new query.

Claims

1. A method for managing a query, the method comprising:

receiving via a computer readable storage medium an iterator model plan based on the query;

transforming through the computer readable storage medium a first operator of the iterator model plan and a first operator variable of the first operator based on an analysis of the iterator model plan and a shared continuous query plan;

generating a continuous query operator based on the transformed first operator variable and the transformed first operator; and

providing the generated continuous query operator to the shared continuous query plan.

2. The method of claim 1, further comprising analyzing the iterator model plan based on at least one of a local range table and a global range table.

3. The method of claim 1, further comprising generating a variable transform for the first operator variable based on the analysis of the iterator model plan and the shared continuous query plan.

4. The method of claim 1, further comprising generating a plan item based on the analysis of the iterator model plan and the continuous query plan.

5. The method of claim 4, wherein generating a continuous query operator further comprises generating the continuous query operator based on the plan item.

6. The method of claim 1, further comprising providing the generated continuous query operator to a routing table.

7. The method of claim 1, wherein the query comprises a continuous query.

8. The method of claim 1, wherein a structure of the iterator model plan is independent of transforming a first operator variable of the iterator model plan.

9. The method of claim 1, wherein the first operator is configured to operate on a stream.

10. The method of claim 1, further comprising:

identifying a set of operators in the iterator model plan that includes the first operator and a second operator;

transforming the second operator and a second operator variable of the second operator based on the iterator model plan and the shared continuous query plan; and

providing the transformed second operator and the transformed second operator variable to the generated continuous query operator.

11. The method of claim 1, wherein the first operator includes a scan operator, a unary operator, a binary operator, or an n-ary operator.

12. The method of claim 1, wherein the first operator is configured to perform an initialization function, a next function, a rescan function, or a close function.

13. The method of claim 1, wherein the continuous query operator is configured to perform at least one of an initialization function, an execute function, an add query function, a remove query function, and an end function.

14. A method for managing a query, the method comprising:

receiving via a computer readable storage medium an iterator model plan and a local range table based on the query;

transforming through the computer readable storage medium a first operator variable of a first operator in the iterator model plan based on an analysis of the iterator model plan and a shared continuous query plan;

identifying a continuous query operator based on the transformed first operator variable and the transformed first operator; and

providing the query to a list of queries associated with the identified continuous query operator.

15. The method of claim 14, wherein the query comprises a continuous query.

16. The method of claim 14, further comprising providing the transformed first operator variable to the identified continuous query operator.

17. The method of claim 14, further comprising providing the transformed first operator variable to a routing table.

18. The method of claim 14, further comprising generating a variable transform for the first operator variable based on the analysis of the iterator model plan and the shared continuous query plan.

19. The method of claim 14, further comprising generating a plan item for the transformed first operator based on the analysis of the iterator model plan and the shared continuous query plan.

20. The method of claim 19, wherein identifying a continuous query operator further comprises identifying the continuous query operator based on the plan item.

21. The method of claim 14, wherein the identified continuous query operator comprises a group of two or more transformed operators of the iterator model plan.

22. A system comprising:

a processor; and

a computer readable storage medium having instructions for execution by the processor which causes the processor to manage a query,

wherein the processor is coupled to the computer readable storage medium, the processor executing the instructions on the computer readable storage medium to;

receive an iterator model plan based on the query,

transform an operator of the iterator model plan and an operator variable of the operator based on an analysis of the iterator model plan and a shared continuous query plan,

generate a continuous query operator based on the transformed operator variable and the transformed operator, and

provide the generated continuous query operator to the shared continuous query plan.

23. The system of claim 22, wherein the query comprises a continuous query.

24. The system of claim 22, wherein the processor is further configured to associate the transformed operator variable with the global range table.

25. The system of claim 22, wherein the continuous query operator includes an input signature list and an output signature list.

26. The system of claim 22, wherein the continuous query operator includes a pointer to a routing table.

27. The system of claim 22, wherein the continuous query operator comprises a sub-plan including a group of two or more related transformed operators of the iterator model plan.

28. A system for managing a query, the system comprising:

a processor; and

a computer readable storage medium having instructions for execution by the processor which causes the processor to manage a query,

wherein the processor is coupled to the computer readable storage medium, the processor executing the instructions on the computer readable storage medium to;

receive an iterator model plan based on the query,

transform an operator variable of an operator of the iterator model plan based on an analysis of the iterator model plan and a shared continuous query plan, and

identify a continuous query operator of the shared continuous query plan, the continuous query operator configured to receive and execute the query.

29. The system of claim 28, wherein the runtime processor is further configured to transform the operator variable based on a local range table and a global range table.

30. The system of claim 28, wherein the continuous query operator is configured to execute a list of queries, the list of queries including the received query.

31. The system of claim 28, wherein the continuous query operator includes an input signature and an output signature.

32. The system of claim 28, wherein the continuous query operator includes a pointer to a routing table.

33. The system of claim 28, wherein the identified continuous query operator comprises a sub-plan including a group of two or more related operators of the iterator model plan.