Row dispersal across parallelized processes during query execution based on forwarding data blocks

A node of a database system includes:

• at least one processor;
• and
• a memory that stores operational instructions that, when executed by the at least one processor, causes the node to:
• executing a row dispersal operator in conjunction with execution of a query to disperse a plurality of input rows across a set of peer nodes based on:
• determining a plurality of input data blocks that collectively includes the plurality of input rows, wherein each input data block in the plurality of input data blocks a corresponding proper subset of the plurality of input rows;
• assigning the each data block of the plurality of input data blocks to a corresponding one of the set of peer nodes for processing in accordance with a uniform assignment scheme;
• and
• forwarding the each data block to the corresponding one of the set of peer nodes by reference.

A database system includes:

• at least one processor;
• and
• a memory that stores operational instructions that, when executed by the at least one processor, causes the database system to:
• determine a query for execution;
• determine, based on the query, a query operator execution flow that includes a row dispersal operator serially before a set of parallelized operations;
• and
• execute the row dispersal operator in conjunction with execution of query operator execution flow for the query to disperse a plurality of input rows across the set of parallelized operations based on:
• determine a plurality of input data blocks that collectively includes the plurality of input rows, wherein each input data block in the plurality of input data blocks a corresponding proper subset of the plurality of input rows;
• assign the each data block of the plurality of input data blocks to a corresponding one of the set of parallelized operations for processing in accordance with a uniform assignment scheme;
• and
• forward the each data block to the corresponding one of the set of parallelized operations by reference.