Skip to main content

read_cdf_batches

Function read_cdf_batches 

Source
pub async fn read_cdf_batches(
    table: DeltaTable,
    start_version: i64,
    end_version: i64,
    max_rows: usize,
    max_bytes: usize,
) -> Result<Vec<RecordBatch>, ConnectorError>
Expand description

Reads CDF batches for a version range via scan_cdf().

scan_cdf(self) consumes the supplied DeltaTable; callers retaining a table handle can pass a clone. Output includes _change_type, _commit_version, _commit_timestamp.

ยงErrors

Returns a read error on scan failure or a non-transient configuration error when the collected version range exceeds either hard limit.