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...