Struct PathAggregateOperator 

pub struct PathAggregateOperator {
    pub path: PathExpr,
    pub agg: AggregationKind,
    pub source: Option<Arc<dyn Operator>>,
}

Aggregate a numeric path across nested arrays per-document. The payload’s score becomes the aggregate value; _path_aggregate and _path_aggregate_path carry the value and the dotted path for downstream consumers.

Fields

path: PathExpr

agg: AggregationKind

source: Option<Arc<dyn Operator>>

Implementations

impl PathAggregateOperator

pub fn new( path: PathExpr, agg: AggregationKind, source: Option<Arc<dyn Operator>>, ) -> Self

Trait Implementations

impl Operator for PathAggregateOperator

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

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