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.