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.