Struct ArrayAggAccumulator 

pub struct ArrayAggAccumulator {
    values: Vec<ArrayRef>,
    datatype: DataType,
    ignore_nulls: bool,
}

Fields

values: Vec<ArrayRef>

datatype: DataType

ignore_nulls: bool

Implementations

impl ArrayAggAccumulator

pub fn try_new(datatype: &DataType, ignore_nulls: bool) -> Result<Self>

new array_agg accumulator based on given item data type

fn get_optional_values_to_merge_as_is( list_array: &ListArray, ) -> Option<ArrayRef>

This function will return the underlying list array values if all valid values are consecutive without gaps (i.e. no null value point to a non-empty list) If there are gaps but only in the end of the list array, the function will return the values without the null values in the end

Trait Implementations

impl Accumulator for ArrayAggAccumulator

fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()>

Updates the accumulator’s state from its input.

fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()>

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

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

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

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

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 ArrayAggAccumulator

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

Formats the value using the given formatter.