Skip to main content

execute_aggregate

cypherlite_query::executor::operators::aggregate

Function execute_aggregate 

Source 
pub fn execute_aggregate(
    source_records: Vec<Record>,
    group_keys: &[Expression],
    aggregates: &[(String, AggregateFunc)],
    engine: &StorageEngine,
    params: &Params,
    scalar_fns: &dyn ScalarFnLookup,
) -> Result<Vec<Record>, ExecutionError>
Expand description

Execute aggregation over source records. Groups by group_keys, computes aggregate functions per group.