Struct PhysicalMergeRel 

pub struct PhysicalMergeRel {

    pub rel_table_name: String,
    pub rel_table_id: u64,
    pub edge_var: String,
    pub src_node_var: String,
    pub dst_node_var: String,
    pub direction: EdgeDirection,
    pub properties: Vec<(String, Expression)>,
    pub on_match: Vec<PhysicalSet>,
    pub on_create: Vec<PhysicalSet>,
    pub table_catalog: Arc<TableCatalog>,
    pub txn_id: Option<u64>,
    pub undo_sink: Option<Arc<Mutex<Vec<UndoRecord>>>>,
    pub wal_sink: Option<WalSink>,
}

Physical operator for MERGE on an edge pattern.

For each input row (a bound src/dst node pair, resolved via the <src>._id / <dst>._id columns), it matches an existing edge on the rel table whose endpoints and pattern properties match. If none exists, a new edge is inserted. Emits one output column <edge_var>._id carrying the matched/inserted edge index per row, so a following SET <edge_var>.x clause can target the right rows.

Fields

rel_table_name: String

rel_table_id: u64

edge_var: String

src_node_var: String

dst_node_var: String

direction: EdgeDirection

properties: Vec<(String, Expression)>

on_match: Vec<PhysicalSet>

on_create: Vec<PhysicalSet>

table_catalog: Arc<TableCatalog>

txn_id: Option<u64>

Active transaction id (P52.18).

undo_sink: Option<Arc<Mutex<Vec<UndoRecord>>>>

Undo sink for rollback records (P52.18).

wal_sink: Option<WalSink>

Typed WAL sink so MERGE-created edges survive restarts via replay (P60.2).

Trait Implementations

impl PhysicalOperatorExec for PhysicalMergeRel

fn operator_type(&self) -> &str

fn execute(&self, input: Vec<DataChunk>) -> OperatorResult