Enum AggregateOp 

pub enum AggregateOp {
    Sum,
    Mean,
    Median,
    Min,
    Max,
    Count,
}

Represents the statistical aggregation operations available for data transformation.

This enum defines how multiple data points are collapsed into a single value during the transformation phase. It is used both in simple aggregations and complex window functions.

Variants

Sum

Total sum of all valid (non-null) values in the group.

Mean

Arithmetic mean (average). Result is NaN if all values are null.

Median

The middle value. Requires a partial sort of the group data.

Min

The smallest value in the group.

Max

The largest value in the group.

Count

The total count of records (including or excluding nulls, based on implementation).

Implementations

impl AggregateOp

pub fn aggregate_by_index(&self, col: &ColumnVector, indices: &[usize]) -> f64

Native aggregation logic: Extracting and aggregating data from columns based on indices.

This method performs statistical calculations directly on the provided ColumnVector using only the specified row indices.

Trait Implementations

impl Clone for AggregateOp

fn clone(&self) -> AggregateOp

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AggregateOp

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

Formats the value using the given formatter.

impl Default for AggregateOp

fn default() -> AggregateOp

Returns the “default value” for a type.

impl From<&str> for AggregateOp

fn from(s: &str) -> Self

Converts to this type from the input type.

impl PartialEq for AggregateOp

fn eq(&self, other: &AggregateOp) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for AggregateOp

impl Eq for AggregateOp

impl StructuralPartialEq for AggregateOp