Struct PhysicalCopyFrom 

pub struct PhysicalCopyFrom {
    pub table_name: String,
    pub table_id: u64,
    pub file_path: String,
    pub columns: Vec<ColumnDefinition>,
    pub options: HashMap<String, String>,
    pub table_catalog: Arc<TableCatalog>,
    pub vfs: Arc<VirtualFileSystemRegistry>,
    pub txn_id: Option<u64>,
    pub undo_sink: Option<Arc<Mutex<Vec<UndoRecord>>>>,
    pub wal_sink: Option<WalSink>,
}

Physical operator for COPY FROM — loads data from CSV/Parquet files into a table.

Detects file type from extension, calls the appropriate reader, and inserts rows into the target table via the TableCatalog.

Fields

table_name: String

table_id: u64

file_path: String

columns: Vec<ColumnDefinition>

options: HashMap<String, String>

table_catalog: Arc<TableCatalog>

vfs: Arc<VirtualFileSystemRegistry>

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 COPY-loaded rows survive restarts via replay (P60.2).

Trait Implementations

impl PhysicalOperatorExec for PhysicalCopyFrom

fn operator_type(&self) -> &str

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