Struct HorizontalAggregateOperator 

pub struct HorizontalAggregateOperator { /* private fields */ }

Per-row aggregation over a list-valued column.

For each input row:

1. Reads a Value::List from list_column_idx (entity IDs from a path)
2. For each entity ID, looks up property via the graph store
3. Feeds property values through an AggregateState
4. Finalizes and appends the result as a new column

Implementations

impl HorizontalAggregateOperator

pub fn new( child: Box<dyn Operator>, list_column_idx: usize, entity_kind: EntityKind, function: AggregateFunction, property: String, store: Arc<dyn GraphStore>, input_column_count: usize, ) -> Self

Creates a new horizontal aggregate operator.

Trait Implementations

impl Operator for HorizontalAggregateOperator

fn next(&mut self) -> OperatorResult

Pulls the next batch of data. Returns None when exhausted.

fn reset(&mut self)

Resets to initial state so you can iterate again.

fn name(&self) -> &'static str

Returns a name for debugging/explain output.