Execution of a query using a dynamic library

A query coordinator comprising:

• a data store;
• and
• one or more processors configured to:
• receive a portion of a query from a first distributed data processing system;
• identify a second distributed data processing system to execute the portion of the query;
• identify a first scheme generator from a plurality of scheme generators based on identifying the second distributed data processing system;
• communicate the portion of the query to the first scheme generator, wherein the first scheme generator generates a query processing scheme using the portion of the query, wherein the query processing scheme comprises a plurality of processing phases for executing the portion of the query by the second distributed data processing system;
• and
• communicate the query processing scheme to a server associated with the second distributed data processing system,
• wherein the query processing scheme indicates resolution of a first portion of the query processing scheme occurs using the server,
• wherein the server communicates the query processing scheme to the second distributed data processing system and resolves the first portion of the query processing scheme for the second distributed data processing system using a dynamic library as the second distributed data processing system generates a query plan, and
• wherein the second distributed data processing system uses the query plan to execute the portion of the query using a plurality of worker nodes of the second distributed data processing system.

Non-transitory computer-readable media including computer-executable instructions that, when executed by a query coordinator, cause the query coordinator to:

• receive a portion of a query from a first distributed data processing system;
• identify a second distributed data processing system to execute the portion of the query;
• identify a first scheme generator from a plurality of scheme generators based on identifying the second distributed data processing system;
• communicate the portion of the query to the first scheme generator, wherein the first scheme generator generates a query processing scheme using the portion of the query, wherein the query processing scheme comprises a plurality of processing phases for executing the portion of the query by the second distributed data processing system;
• and
• communicate the query processing scheme to a server associated with the second distributed data processing system,
• wherein the query processing scheme indicates resolution of a first portion of the query processing scheme occurs using the server,
• wherein the server communicates the query processing scheme to the second distributed data processing system and resolves the first portion of the query processing scheme for the second distributed data processing system using a dynamic library as the second distributed data processing system generates a query plan, and
• wherein the second distributed data processing system uses the query plan to execute the portion of the query using a plurality of worker nodes of the second distributed data processing system.