Struct AggregateOperator 

pub struct AggregateOperator {
    pub source: Option<Arc<dyn Operator>>,
    pub field: String,
    pub monoid: Arc<dyn AggregationMonoid>,
}

Apply a monoid over a single field across the rows the source operator produces. Emits a one-entry posting list whose payload carries _aggregate_field / _aggregate so downstream callers can pick the result by name.

Fields

source: Option<Arc<dyn Operator>>

field: String

monoid: Arc<dyn AggregationMonoid>

Implementations

impl AggregateOperator

pub fn new( source: Option<Arc<dyn Operator>>, field: impl Into<String>, monoid: Arc<dyn AggregationMonoid>, ) -> Self

Trait Implementations

impl Operator for AggregateOperator

fn execute(&self, ctx: &ExecutionContext) -> OperatorResult

fn cost_estimate(&self, stats: &IndexStats) -> f64