Skip to main content

should_use_single_for_parallel

alopex_sql::executor::query::aggregate

Function should_use_single_for_parallel 

Source 
pub fn should_use_single_for_parallel(
    parallelism: usize,
    aggregates: &[AggregateExpr],
) -> bool
Expand description

Return true when aggregate execution must remain Single for correctness. FILTER is applied per input row and therefore commutes with Partial/Final splitting; ordered aggregates (aggregate-local ORDER BY and ordered-set aggregates such as PERCENTILE_DISC) buffer whole groups and stay Single (issue #148, D11).