scan_task_to_chunk_with_deletes

Function scan_task_to_chunk_with_deletes 

Source
pub fn scan_task_to_chunk_with_deletes(
    table: Table,
    data_file_scan_task: FileScanTask,
    _: IcebergScanOpts,
    metrics: Option<Arc<IcebergScanMetrics>>,
) -> impl Stream<Item = Result<DataChunk, ConnectorError>>
Expand description

Scan a data file and optionally apply delete files (both position delete and equality delete). This implementation follows the iceberg-rust process_file_scan_task logic for proper delete handling.