Struct ExpandOperator 

pub struct ExpandOperator { /* private fields */ }

An expand operator that traverses edges from source nodes.

For each input row containing a source node, this operator produces output rows for each neighbor connected via matching edges.

Implementations

impl ExpandOperator

pub fn new( store: Arc<LpgStore>, input: Box<dyn Operator>, source_column: usize, direction: Direction, edge_type: Option<String>, ) -> Self

Creates a new expand operator.

pub fn with_chunk_capacity(self, capacity: usize) -> Self

Sets the chunk capacity.

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

Sets the transaction context for MVCC visibility.

When set, the expand will only traverse visible edges and nodes.

Trait Implementations

impl Operator for ExpandOperator

fn next(&mut self) -> OperatorResult

Returns the next chunk of data, or None if exhausted.

fn reset(&mut self)

Resets the operator to its initial state.

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

Returns the name of this operator for debugging.