pub async fn read_batches_at_version(
table: &mut DeltaTable,
version: i64,
max_records: usize,
) -> Result<(Vec<RecordBatch>, bool), ConnectorError>Expand description
Reads record batches from a specific Delta Lake table version.
Loads the requested version, applies a LIMIT to bound memory usage,
then streams results via execute_stream to avoid materializing the
entire version in memory.
§Arguments
table- Mutable reference to the Delta Lake table handleversion- The table version to readmax_records- Maximum number of records to return. Passusize::MAXto read all records (unbounded).
§Errors
Returns ConnectorError::ReadError if the version cannot be loaded or scanned.
Returns (batches, fully_consumed) — fully_consumed is false when
max_records truncated the result and more rows remain.