pavlospt opened a new pull request, #51:
URL: https://github.com/apache/fluss-rust/pull/51
## Description
This PR adds integration test coverage for scanning records after appending
them, completing the test requirements outlined in issue #30.
## Changes
- ✅ Enhanced the existing `append_record_batch()` test to verify scanned
records
- ✅ Added scanner creation and subscription to bucket 0 starting from offset 0
- ✅ Implemented comprehensive verification of appended data:
- Record count validation (6 records total)
- Individual field value assertions for c1 (Int32) and c2 (String) columns
- ✅ Added necessary imports (`TableBucket`, `InternalRow`)
## Test Coverage
The test now:
1. Appends two batches of Arrow records (6 records total)
2. Creates a log scanner and subscribes to the table bucket
3. Polls for records with timeout
4. Verifies all 6 records are scanned correctly
5. Validates each record's field values match the appended data
## Verification
```bash
cargo test --test test_fluss --features integration_tests append_record_batch
```
Test passes successfully in ~118s.
Fixes #30
--
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]
