Struct ExpandOperator 

pub struct ExpandOperator { /* private fields */ }

Expand operator: -[:KNOWS]->

Implementations

impl ExpandOperator

pub fn new( input: OperatorBox, source_var: String, target_var: String, edge_var: Option<String>, edge_types: Vec<String>, direction: Direction, ) -> Self

Create a new expand operator

pub fn with_path_variable(self, var: String) -> Self

Set path variable for named path materialization (CY-04)

pub fn with_target_labels(self, labels: Vec<Label>) -> Self

Set target node labels to filter during expansion

Trait Implementations

impl PhysicalOperator for ExpandOperator

fn next(&mut self, store: &GraphStore) -> ExecutionResult<Option<Record>>

Get the next record from this operator (read-only operations)

fn next_batch( &mut self, store: &GraphStore, batch_size: usize, ) -> ExecutionResult<Option<RecordBatch>>

Get the next batch of records (Vectorized Execution) Defaults to accumulating records from next()

fn reset(&mut self)

Reset the operator to start from the beginning

fn describe(&self) -> OperatorDescription

Describe this operator for EXPLAIN output Returns (operator_name, details, children)

fn next_batch_mut( &mut self, store: &mut GraphStore, tenant_id: &str, batch_size: usize, ) -> ExecutionResult<Option<RecordBatch>>

Get the next batch of records for mutating operations

fn next_mut( &mut self, store: &mut GraphStore, _tenant_id: &str, ) -> ExecutionResult<Option<Record>>

Get the next record from this operator (write operations that mutate the store)

fn is_mutating(&self) -> bool

Returns true if this operator mutates the graph store