Struct TrivialFirstValueAccumulator 

pub struct TrivialFirstValueAccumulator {
    first: ScalarValue,
    is_set: bool,
    ignore_nulls: bool,
}

This accumulator is used when there is no ordering specified for the FIRST_VALUE aggregation. It simply returns the first value it sees according to the pre-existing ordering of the input data, and provides a fast path for this case without needing to maintain any ordering state.

Fields

first: ScalarValue

is_set: bool

ignore_nulls: bool

Implementations

impl TrivialFirstValueAccumulator

pub fn try_new( data_type: &DataType, ignore_nulls: bool, ) -> Result<TrivialFirstValueAccumulator, DataFusionError>

Creates a new TrivialFirstValueAccumulator for the given data_type.

Trait Implementations

impl Accumulator for TrivialFirstValueAccumulator

fn state(&mut self) -> Result<Vec<ScalarValue>, DataFusionError>

Returns the intermediate state of the accumulator, consuming the intermediate state.

fn update_batch( &mut self, values: &[Arc<dyn Array>], ) -> Result<(), DataFusionError>

Updates the accumulator’s state from its input.

fn merge_batch( &mut self, states: &[Arc<dyn Array>], ) -> Result<(), DataFusionError>

Updates the accumulator’s state from an Array containing one or more intermediate values.

fn evaluate(&mut self) -> Result<ScalarValue, DataFusionError>

Returns the final aggregate value, consuming the internal state.

fn size(&self) -> usize

Returns the allocated size required for this accumulator, in bytes, including Self.

fn retract_batch( &mut self, _values: &[Arc<dyn Array>], ) -> Result<(), DataFusionError>

Retracts (removed) an update (caused by the given inputs) to accumulator’s state.

fn supports_retract_batch(&self) -> bool

Does the accumulator support incrementally updating its value by removing values.

impl Debug for TrivialFirstValueAccumulator

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.