Struct PhysicalSet 

pub struct PhysicalSet {
    pub table_name: String,
    pub table_id: u64,
    pub is_node: bool,
    pub items: Vec<SetItem>,
    pub table_catalog: Arc<TableCatalog>,
    pub txn_id: Option<u64>,
    pub undo_sink: Option<Arc<Mutex<Vec<UndoRecord>>>>,
    pub function_registry: Option<Arc<Mutex<FunctionRegistry>>>,
    pub emit_count: bool,
    pub wal_sink: Option<WalSink>,
}

Physical operator for SET — updates properties on matched rows.

All items of a SET clause are evaluated against the SAME pre-update snapshot of the table, then written (atomic semantics, P53.17). This means SET n.a = n.a + 1, n.b = n.a * 10 computes both RHS values from the pre-update n.a, matching Cypher/Neo4j behavior.

Fields

table_name: String

table_id: u64

is_node: bool

items: Vec<SetItem>

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).

function_registry: Option<Arc<Mutex<FunctionRegistry>>>

Function registry for evaluating non-constant SET value expressions (arithmetic, property reads, function calls) against old row data (P53.17).

emit_count: bool

True when SET is terminal (no trailing RETURN): empty match reports a count=0 row. False when RETURN follows: empty match must flow 0 rows, not a phantom count row (P53.39 / kairos P59.1).

wal_sink: Option<WalSink>

Typed WAL sink so updates survive restarts via WAL replay (P60.2).

Trait Implementations

impl PhysicalOperatorExec for PhysicalSet

fn operator_type(&self) -> &str

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