Supporting additional query languages through distributed execution of query engines

A system comprising:

• a data store including computer-executable instructions;
• and
• a processor in communication with the data store and configured to execute the computer-executable instructions to:
• receive a query in a first query language to be applied to a set of data records;
• parse the query to identify multiple query stages;
• generate, for each query stage of the multiple query stages, a sub-query, in the first query language, that when executed at each of multiple worker nodes, implements the query stage with respect to a subset of the records obtained at the worker node;
• generate instructions for shuffling records between the multiple worker nodes at a point in time between at least two of the multiple query stages;
• and
• communicate the sub-query for each query stage and the instructions for shuffling records to the multiple worker nodes for concurrent implementation, wherein each worker node includes a first query language executor to execute the sub-query for each query stage with respect to the subset of records obtained at the worker node.

Non-transitory computer-readable media comprising computer-executable instructions that, when executed by a computing system, cause the computing system to:

• receive a query in a first query language to be applied to a set of data records;
• parse the query to identify multiple query stages;
• generate, for each query stage of the multiple query stages, a sub-query, in the first query language, that when executed at each of multiple worker nodes, implements the query stage with respect to a subset of the records obtained at the worker node;
• generate instructions for shuffling records between the multiple worker nodes at a point in time between at least two of the multiple query stages;
• and
• communicate the sub-query for each query stage and the instructions for shuffling records to the multiple worker nodes for concurrent implementation, wherein each worker node includes a first query language executor to execute the sub-query for each query stage with respect to the subset of records obtained at the worker node.