Method for serial and condition-based execution of operators by parallel processes

• US 8,954,419 B2
• Filed: 05/22/2012
• Issued: 02/10/2015
• Est. Priority Date: 05/22/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Apte, Himani, Cruanes, Thierry
• Primary Examiner(s): Ly, Anh
• Application Number:
  US13/478,065
• Publication Number:
  US 20130318068A1
• Time in Patent Office: 994 Days
• Field of Search: 707/764, 707/718, 707/719, 707/713, 707/623, 707/E17.017, 707/E17.131, 707/803, 707/809, 707/64, 707/96, 707/636, 709/200, 709/205, 709/206
• US Class Current: 707/718
• CPC Class Codes: G06F 15/16 Combinations of two or more digital computers each having at least an arithmetic unit, a program unit and a register, e.g. for a simultaneous processing of several programs coordinating program control therefor G06F9/52; in regulating and control system G05B
• CPC Class Codes: G06F 16/24532 of parallel queries
• CPC Class Codes: G06F 16/24557 Efficient disk access during query execution

Abstract

Techniques are provided for improving performance of parallel execution plans that include serial operations. A database server generates a parallel execution plan and includes one or more serial data flow objects in the parallel execution plan, each data flow object including one or more serial row sources. A parallel selector row source is associated with each serial data flow object included in the parallel execution plan. Each parallel selector row source coordinates with a query coordinator process the execution of the associated serial data flow object. In the event that that a plurality of serial data flow objects are included in a parallel execution plan, serial row sources included in the serial data flow objects may be executed concurrently by a separate parallel slave process, instead of sequential execution of each serial row source by the query coordinator process.

Claims

1. A method comprising:

a query coordinator and a plurality of slave processes executing a query execution plan that comprises (a) a parallel row source executed as multiple subtasks by multiple slave processes of said plurality of slave processes and (b) one or more serial row sources, wherein each serial row source of the one or more serial row sources is executed by only one slave process;

wherein executing said query execution plan comprises;

the query coordinator assigning a first subtask of said multiple subtasks to a first slave process of said multiple slave processes and assigning a second subtask of said multiple subtasks to a second slave process;

said first slave process executing said first subtask and said second slave process executing said second subtask;

a particular slave process of said plurality of slave processes sending, to said query coordinator, a request to execute a particular serial row source of said one or more serial row sources;

in response to receiving said request to execute said particular serial row source, said query coordinator determining that said particular row source is not assigned to a slave process of said plurality of slave processes; and

based on determining that said particular serial row source is not assigned to a slave process of said plurality of slave processes, said query coordinator assigning the particular serial row source of said one or more serial row sources to said particular slave process of said plurality of slave processes;

wherein the method is performed by one or more computing devices.

2. The method of claim 1, further comprising:

said second slave process of said plurality of slave processes sending, to said query coordinator, a request to execute said particular serial row source;

in response to receiving said request to execute said particular serial row source of said one or more serial row sources, said query coordinator determining that said particular serial row source is assigned to said particular slave process;

based on determining that said particular serial row source is assigned to said particular slave process, said query coordinator not assigning said particular serial row source to said second slave process.

3. The method of claim 1, wherein said request is based on a remote procedure call.

4. The method of claim 1, wherein said query execution plan includes a parallel selector row source, wherein said parallel selector row source causes said particular slave process to send said request to said query coordinator to execute said particular serial row source.

5. The method of claim 1, wherein said query execution plan is a query execution plan for a Structured Query Language (SQL) statement.

6. The method of claim 1, further comprising:

in response to receiving said request to execute said particular serial row source of said one or more serial row sources, said query coordinator determining whether to assign said particular serial row source to said slave process based on one or more global conditions.

7. A non-transitory computer-readable medium storing instructions which, when executed by one or more processors, cause:

a query coordinator and a plurality of slave processes executing a query execution plan that comprises (a) a parallel row source executed as multiple subtasks by multiple slave processes of said plurality of slave processes and (b) one or more serial row sources, wherein each serial row source of the one or more serial row sources is executed by only one slave process;

wherein executing said query execution plan comprises;

the query coordinator assigning a first subtask of said multiple subtasks to a first slave process of said multiple slave processes and assigning a second subtask of said multiple subtasks to a second slave process;

said first slave process executing said first subtask and said second slave process executing said second subtask;

a particular slave process of said plurality of slave processes sending, to said query coordinator, a request to execute a particular serial row source of said one or more serial row sources;

in response to receiving said request to execute said particular serial row source, said query coordinator determining that said particular row source is not assigned to a slave process of said plurality of slave processes; and

based on determining that said particular serial row source is not assigned to a slave process of said plurality of slave processes, said query coordinator assigning the particular serial row source of said one or more serial row sources to said particular slave process of said plurality of slave processes.

8. The non-transitory computer-readable medium of claim 7, wherein the instructions further include instructions for:

said second slave process of said plurality of slave processes sending, to said query coordinator, a request to execute said particular serial row source;

in response to receiving said request to execute said particular serial row source of said one or more serial row sources, said query coordinator determining that said particular serial row source is assigned to said particular slave process;

based on determining that said particular serial row source is assigned to said particular slave process, said query coordinator not assigning said particular serial row source to said second slave process.

9. The non-transitory computer-readable medium of claim 7, wherein said request is based on a remote procedure call.

10. The non-transitory computer-readable medium of claim 7, wherein said query execution plan includes a parallel selector row source, wherein said parallel selector row source causes said particular slave process to send said request to said query coordinator to execute said particular serial row source.

11. The non-transitory computer-readable medium of claim 7, wherein said query execution plan is a query execution plan for a Structured Query Language (SQL) statement.

12. The non-transitory computer-readable medium of claim 7, the instructions further comprising instructions for in response to receiving said request to execute said particular serial row source of said one or more serial row sources, said query coordinator determining whether to assign said particular serial row source to said slave process based on one or more global conditions.