[−][src]Trait datafusion::execution::physical_plan::Accumulator

pub trait Accumulator {
    fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()>;
    fn accumulate_batch(&mut self, array: &ArrayRef) -> Result<()>;
    fn get_value(&self) -> Result<Option<ScalarValue>>;
}

Aggregate accumulator

Required methods

`fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()>`

Update the accumulator based on a row in a batch

`fn accumulate_batch(&mut self, array: &ArrayRef) -> Result<()>`

Update the accumulator based on an array in a batch

`fn get_value(&self) -> Result<Option<ScalarValue>>`

Get the final value for the accumulator

Loading content...

Implementors

Loading content...