Struct LazyFactorizedChainOperator 

pub struct LazyFactorizedChainOperator { /* private fields */ }

A lazy operator that executes a factorized expand chain when next() is called.

Unlike FactorizedExpandChain which executes immediately during construction, this operator defers execution until query runtime. This is critical for correctness when filters are applied above the expand chain.

Factorized Aggregation Support

This operator supports returning factorized results via next_factorized(). When the downstream operator can handle factorized data (e.g., factorized aggregation), this avoids flattening and provides massive speedups.

Implementations

impl LazyFactorizedChainOperator

pub fn new( store: Arc<LpgStore>, source: Box<dyn Operator>, steps: Vec<ExpandStep>, ) -> Self

Creates a new lazy factorized chain operator.

pub fn with_tx_context(self, epoch: EpochId, tx_id: Option<TxId>) -> Self

Sets the transaction context for MVCC visibility.

pub fn next_factorized(&mut self) -> FactorizedResult

Returns the factorized result without flattening.

Use this when the next operator can handle factorized data (e.g., factorized aggregation). This is the key to 10-100x speedups for aggregate queries on multi-hop traversals.

Returns

The factorized chunk, or None if exhausted or no results.

Trait Implementations

impl FactorizedOperator for LazyFactorizedChainOperator

fn next_factorized(&mut self) -> FactorizedResult

Returns the next chunk as factorized data.

impl Operator for LazyFactorizedChainOperator

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.