Skip to main content

DynGroupedAccumulator

vortex_array::aggregate_fn

Trait DynGroupedAccumulator 

Source 
pub trait DynGroupedAccumulator: 'static + Send {
    // Required methods
    fn accumulate_list(
        &mut self,
        groups: &ArrayRef,
        ctx: &mut ExecutionCtx,
    ) -> VortexResult<()>;
    fn flush(&mut self) -> VortexResult<ArrayRef>;
    fn finish(&mut self) -> VortexResult<ArrayRef>;
}
Expand description

A trait object for type-erased grouped accumulators, used for dynamic dispatch when the aggregate function is not known at compile time.

Required Methods§

Source

fn accumulate_list( &mut self, groups: &ArrayRef, ctx: &mut ExecutionCtx, ) -> VortexResult<()>

Accumulate a list of groups into the accumulator.

Source

fn flush(&mut self) -> VortexResult<ArrayRef>

Finish the accumulation and return the partial aggregate results for all groups. Resets the accumulator state for the next round of accumulation.

Source

fn finish(&mut self) -> VortexResult<ArrayRef>

Finish the accumulation and return the final aggregate results for all groups. Resets the accumulator state for the next round of accumulation.

Implementors§