slfan1989 opened a new pull request, #559:
URL: https://github.com/apache/fluss-rust/pull/559
### Purpose
Linked issue: close #558
Add Rust-level integration coverage for `RecordBatchLogReader` bounded reads.
`RecordBatchLogReader` already has unit coverage for batch filtering and
Python binding coverage for `to_arrow_batch_reader` guard/drop behavior, but it
lacks Rust end-to-end integration coverage for:
- `new_until_offsets` stopping semantics
- `new_until_latest` with partitioned log tables
This PR adds those missing integration tests.
### Brief change log
- Added a Rust integration test for
`RecordBatchLogReader::new_until_offsets`.
- Creates a log table.
- Appends records.
- Subscribes from a non-zero offset.
- Reads with an explicit stopping offset.
- Verifies records at or beyond the stop offset are not returned.
- Added a Rust integration test for `RecordBatchLogReader::new_until_latest`
on partitioned tables.
- Creates a partitioned log table.
- Adds `US` and `EU` partitions.
- Appends records to both partitions.
- Subscribes partition buckets.
- Verifies all records present at reader creation are returned.
- Updated the comment in `RecordBatchLogReader` to point to the new Rust
integration coverage.
### Tests
Verified locally.
### API and Format
No API or storage format changes.
### Documentation
No user-facing documentation changes.
--
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]
