Struct MinMaxStructState 

struct MinMaxStructState {
    min_max: Vec<Option<StructArray>>,
    data_type: DataType,
    total_data_bytes: usize,
}

Fields

min_max: Vec<Option<StructArray>>

The minimum/maximum value for each group

data_type: DataType

The data type of the array

total_data_bytes: usize

The total bytes of the string data (for pre-allocating the final array, and tracking memory usage)

Implementations

impl MinMaxStructState

Implement the MinMaxStructState with a comparison function for comparing structs

fn new(data_type: DataType) -> Self

Create a new MinMaxStructState

Arguments:

• data_type: The data type of the arrays that will be passed to this accumulator

fn set_value(&mut self, group_index: usize, new_val: &StructArray)

Set the specified group to the given value, updating memory usage appropriately

fn update_batch<F>( &mut self, array: &StructArray, group_indices: &[usize], total_num_groups: usize, cmp: F, ) -> Result<()>

where F: FnMut(&StructArray, &StructArray) -> bool + Send + Sync,

Updates the min/max values for the given string values

cmp is the comparison function to use, called like cmp(new_val, existing_val) returns true if the new_val should replace existing_val

fn emit_to(&mut self, emit_to: EmitTo) -> (usize, Vec<Option<StructArray>>)

Emits the specified min_max values

Returns (data_capacity, min_maxes), updating the current value of total_data_bytes

• data_capacity: the total length of all strings and their contents,
• min_maxes: the actual min/max values for each group

fn size(&self) -> usize

Trait Implementations

impl Debug for MinMaxStructState

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

Formats the value using the given formatter.