Query execution via communication with an object storage system via an object storage communication protocol

A data processing system comprising:

• at least one processor;
• and
• at least one memory storing operational instructions that, when executed by the at least one processor, cause the at least one processor to perform operations that include:
• determining a query for execution;
• generating a query operator execution flow for the query that includes a first at least one operator serially before a second at least one operator;
• and
• executing the query to generate a query resultant based on:
• executing the first at least one operator of the query operator execution flow based on:
• generating, based on the query, a request for rows in accordance with an object storage communication protocol indicating filtering parameter data parameter;
• sending the request to an object storage system;
• and
• receiving a response indicating a filtered row set from the object storage system as a proper subset of a plurality of records stored by the object storage system that compare favorably to the filtering parameter data based on the object storage system processing the request;
• and
• executing the second at least one operator of the query operator execution flow based on:
• processing the filtered row set indicated in the response in accordance with the second at least one operator to produce the query resultant.

A non-transitory computer readable storage medium comprises:

• at least one memory section that stores operational instructions that, when executed by at least one processing module that includes a processor and a memory, causes the at least one processing module to perform operations that include:
• determining a query for execution;
• generating a query operator execution flow for the query that includes a first at least one operator serially before a second at least one operator;
• and
• executing the query to generate a query resultant based on:
• executing the first at least one operator of the query operator execution flow based on:
• generating, based on the query, a request for rows in accordance with an object storage communication protocol indicating filtering parameter data parameter;
• sending the request to an object storage system;
• and
• receiving a response indicating a filtered row set from the object storage system as a proper subset of a plurality of records stored by the object storage system that compare favorably to the filtering parameter data based on the object storage system processing the request;
• and
• executing the second at least one operator of the query operator execution flow based on:
• processing the filtered row set indicated in the response in accordance with the second at least one operator to produce the query resultant.