fresh-borzoni opened a new pull request, #154:
URL: https://github.com/apache/fluss-rust/pull/154
### Purpose
Linked issue: close #153
Add a `poll()` method to Python LogScanner for incremental, timeout-based
record reading.
### Brief change log
- Add `LogScanner.poll(timeout_ms)` method to Python bindings
- Implement input validation for timeout parameter (rejects negative
values)
- Return empty PyArrow table (with correct schema) on timeout instead of
error
- Add example usage demonstrating poll-based consumption pattern
### API and Format
- New public API: `LogScanner.poll(timeout_ms: int) -> pyarrow.Table`
- No storage format 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]
