Skip to main content

merge_exact_aggregate_states

alopex_sql::executor::query::aggregate

Function merge_exact_aggregate_states 

Source 
pub fn merge_exact_aggregate_states(
    aggregates: &[AggregateExpr],
    partial_rows: impl IntoIterator<Item = Vec<Vec<SqlValue>>>,
) -> Result<Vec<SqlValue>>
Expand description

Merge only aggregate states whose merge rule is proven to preserve the current local SQL result. This is the coordinator-side kernel used by the distributed result assembler after every worker has acknowledged cleanup.