Struct MinMaxStructAccumulator 

pub(crate) struct MinMaxStructAccumulator {
    inner: MinMaxStructState,
    is_min: bool,
}

Accumulator for MIN/MAX operations on Struct data types.

This accumulator tracks the minimum or maximum struct value encountered during aggregation, depending on the is_min flag.

The comparison is done based on the struct fields in order.

Fields

inner: MinMaxStructState

Inner data storage.

is_min: bool

if true, is MIN otherwise is MAX

Implementations

impl MinMaxStructAccumulator

pub fn new_min(data_type: DataType) -> Self

pub fn new_max(data_type: DataType) -> Self

Trait Implementations

impl GroupsAccumulator for MinMaxStructAccumulator

fn update_batch( &mut self, values: &[ArrayRef], group_indices: &[usize], opt_filter: Option<&BooleanArray>, total_num_groups: usize, ) -> Result<()>

Updates the accumulator’s state from its arguments, encoded as a vector of [ArrayRef]s.

fn evaluate(&mut self, emit_to: EmitTo) -> Result<ArrayRef>

Returns the final aggregate value for each group as a single RecordBatch, resetting the internal state.

fn state(&mut self, emit_to: EmitTo) -> Result<Vec<ArrayRef>>

Returns the intermediate aggregate state for this accumulator, used for multi-phase grouping, resetting its internal state.

fn merge_batch( &mut self, values: &[ArrayRef], group_indices: &[usize], opt_filter: Option<&BooleanArray>, total_num_groups: usize, ) -> Result<()>

Merges intermediate state (the output from [Self::state]) into this accumulator’s current state.

fn convert_to_state( &self, values: &[ArrayRef], opt_filter: Option<&BooleanArray>, ) -> Result<Vec<ArrayRef>>

Converts an input batch directly to the intermediate aggregate state.

fn supports_convert_to_state(&self) -> bool

Returns true if [Self::convert_to_state] is implemented to support intermediate aggregate state conversion.

fn size(&self) -> usize

Amount of memory used to store the state of this accumulator, in bytes.