Struct MergeRelationshipOperator 

pub struct MergeRelationshipOperator { /* private fields */ }

Merge operator for relationship patterns.

Takes input rows containing source and target node IDs, then for each row:

1. Searches for an existing relationship matching the type and properties
2. If found, applies ON MATCH properties and returns the existing edge
3. If not found, creates a new relationship and applies ON CREATE properties

Implementations

impl MergeRelationshipOperator

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

Creates a new merge relationship operator.

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 MergeRelationshipOperator

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.