Skip to main content

Accumulator

Trait Accumulator 

Source
pub trait Accumulator: Send + Sync {
    // Required methods
    fn update(
        &mut self,
        args: &Columns,
        groups: &GroupByView,
    ) -> Result<(), FunctionError>;
    fn finalize(&mut self) -> Result<(Vec<GroupKey>, ColumnData), FunctionError>;
}

Required Methods§

Source

fn update( &mut self, args: &Columns, groups: &GroupByView, ) -> Result<(), FunctionError>

Source

fn finalize(&mut self) -> Result<(Vec<GroupKey>, ColumnData), FunctionError>

Implementors§