Struct MergeOperator 

pub struct MergeOperator { /* private fields */ }

Merge operator for MERGE clause.

Tries to match a node with the given labels and properties. If found, returns the existing node. If not found, creates a new node.

When an input operator is provided (chained MERGE), input rows are passed through with the merged node ID appended as an additional column.

Implementations

impl MergeOperator

pub fn new( store: Arc<dyn GraphStoreMut>, input: Option<Box<dyn Operator>>, config: MergeConfig, ) -> Self

Creates a new merge operator.

pub fn variable(&self) -> &str

Returns the variable name for the merged node.

pub fn with_transaction_context( self, epoch: EpochId, transaction_id: Option<TransactionId>, ) -> Self

Sets the transaction context for versioned mutations.

pub fn with_validator(self, validator: Arc<dyn ConstraintValidator>) -> Self

Sets the constraint validator for schema enforcement.

Trait Implementations

impl Operator for MergeOperator

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.