Trait datafusion::execution::physical_plan::Accumulator

pub trait Accumulator {
    fn accumulate(
        &mut self, 
        batch: &RecordBatch, 
        row_index: usize
    ) -> Result<()>;
    fn get_value(&self) -> Result<Option<ScalarValue>>;
}

Aggregate accumulator

Required methods

fn accumulate(&mut self, batch: &RecordBatch, row_index: usize) -> Result<()>

Update the accumulator based on a row in a batch

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

Get the final value for the accumulator

Loading content...

Implementors

Loading content...