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<MinAccumulator, DataFusionError>

new min accumulator

Trait Implementations

impl Accumulator for MinAccumulator

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

Returns the intermediate state of the accumulator.

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(&self) -> Result<ScalarValue, DataFusionError>

Returns the final aggregate value.

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 MinAccumulator

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

Formats the value using the given formatter.