datafusion_functions_aggregate_common::aggregate::groups_accumulator::accumulate

Function accumulate_indices

Source 
pub fn accumulate_indices<F>(
    group_indices: &[usize],
    nulls: Option<&NullBuffer>,
    opt_filter: Option<&BooleanArray>,
    index_fn: F,
)
where
    F: FnMut(usize) + Send,
Expand description

This function is called to update the accumulator state per row when the value is not needed (e.g. COUNT)

F: Invoked like `value_fn(group_index) for all non null values passing the filter. Note that no tracking is done for null inputs or which groups have seen any values

See NullState::accumulate, for more details on other arguments.