Struct datafusion_physical_expr::expressions::MinAccumulator

pub struct MinAccumulator { /* private fields */ }

An accumulator to compute the minimum value

Implementations

impl MinAccumulator

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

new min accumulator

Trait Implementations

impl Accumulator for MinAccumulator

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

Returns the partial intermediate state of the accumulator. This partial state is serialied as Arrays and then combined with other partial states from different instances of this accumulator (that ran on different partitions, for example).

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

Updates the accumulator’s state from a vector of arrays.

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

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

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

Returns the final aggregate value based on its current state.

fn size(&self) -> usize

Allocated size required for this accumulator, in bytes, including Self. Allocated means that for internal containers such as Vec, the capacity should be used not the len

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

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

impl Debug for MinAccumulator

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

Formats the value using the given formatter.