slfan1989 opened a new issue, #558:
URL: https://github.com/apache/fluss-rust/issues/558
### Motivation
`RecordBatchLogReader` has unit coverage for batch filtering, and Python
coverage for the binding-level `to_arrow_batch_reader` guard/drop behavior, but
Rust-level end-to-end coverage is still missing for bounded reader semantics.
A small integration-test PR can cover this without changing production
behavior.
### Proposed coverage
Add Rust integration tests using `FlussTestingCluster` for:
- `RecordBatchLogReader::new_until_offsets` stopping semantics
- subscribe from a non-zero offset
- stop before an explicit upper offset
- verify records at or beyond the stop offset are not returned
- `RecordBatchLogReader::new_until_latest` on partitioned log tables
- create a partitioned table
- append records to multiple partitions
- subscribe partition buckets
- verify all records present at reader creation are returned
--
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]
