Struct CreateEdgeOperator 

pub struct CreateEdgeOperator { /* private fields */ }

Operator that creates new edges.

Implementations

impl CreateEdgeOperator

pub fn new( store: Arc<LpgStore>, input: Box<dyn Operator>, from_column: usize, to_column: usize, edge_type: String, output_schema: Vec<LogicalType>, ) -> Self

Creates a new edge creation operator.

Use builder methods to set additional options:

• with_properties - set edge properties
• with_output_column - output the created edge ID
• with_tx_context - set transaction context

pub fn with_properties(self, properties: Vec<(String, PropertySource)>) -> Self

Sets the properties to assign to created edges.

pub fn with_output_column(self, column: usize) -> Self

Sets the output column for the created edge ID.

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

Sets the transaction context for MVCC versioning.

Trait Implementations

impl Operator for CreateEdgeOperator

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.