Skip to main content

execute_parallel_aggregate_rows

Function execute_parallel_aggregate_rows 

Source
pub fn execute_parallel_aggregate_rows<'a>(
    input: Box<dyn RowIterator + 'a>,
    group_keys: Vec<TypedExpr>,
    aggregates: Vec<AggregateExpr>,
    having: Option<TypedExpr>,
    final_schema: Vec<ColumnMetadata>,
    parallelism: usize,
) -> Result<Vec<Row>>
Expand description

Execute a deterministic single-process parallel partial-to-final aggregate.