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,
) -> Result<Vec<RecordBatch>, ConnectorError>
Expand description

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

scan_cdf(self) consumes the DeltaTable — caller must re-open afterward. Output includes _change_type, _commit_version, _commit_timestamp.

§Errors

Returns ConnectorError::ReadError on scan failure.