Struct PhysicalDelete 

pub struct PhysicalDelete {
    pub table_name: String,
    pub table_id: u64,
    pub primary_key_column: String,
    pub is_node: bool,
    pub detach: bool,
    pub row_indices: Vec<u64>,
    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 DELETE — removes rows from a node or rel table.

Fields

table_name: String

table_id: u64

primary_key_column: String

is_node: bool

detach: bool

row_indices: Vec<u64>

Row indices to delete (found by the scan/filter pipeline).

table_catalog: Arc<TableCatalog>

txn_id: Option<u64>

Active transaction id — deletes are recorded in VersionInfo for MVCC (P52.18).

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

Undo sink for rollback records (P52.18).

wal_sink: Option<WalSink>

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

Trait Implementations

impl PhysicalOperatorExec for PhysicalDelete

fn operator_type(&self) -> &str

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