fresh-borzoni opened a new pull request, #211: URL: https://github.com/apache/fluss-rust/pull/211
close #179
### Purpose
Add ScanBatch struct - batch-level equivalent of ScanRecord that wraps
Arrow RecordBatch with bucket and offset metadata.
### Brief change log
- Add ScanBatch struct to record/mod.rs with bucket, batch, and
base_offset fields
- Add fetch_batches_with_offsets() to CompletedFetch trait to return
batches with their offsets
- Update poll_batches() chain to return Vec<ScanBatch> instead of
Vec<RecordBatch>
This enables downstream consumers to track per-bucket progress and
determine stopping conditions when using the batch API.
### API and Format
No breaking changes. poll_batches() return type changes from
Vec<RecordBatch> to Vec<ScanBatch> (internal API).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
