fresh-borzoni opened a new issue, #316: URL: https://github.com/apache/fluss-rust/issues/316
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss-rust/issues) and found nothing similar. ### Description Add .limit(n) to TableScan and a new BatchScanner struct that sends a single LimitScanRequest RPC. TableScan struct (line 54): add limit: Option<i32> field and guards to rejst New create_batch_scanner(table_bucket: TableBucket) method: requires self.limit.is_some(), constructs and returns BatchScanner. BatchScanner is a one-shot bounded scanner that fires a single LimitScanRequest RPC eagerly in the constructor (following the Lookuper leader-resolution pattern), then returns all data on the first poll_batch() and None on the second. The main complexity is dual deserialization as log tables come back as Arrow IPC and go through the existing LogRecordBatch::record_batch() path, while PK tables come back as KV-format bytes requiring a new CompactedRow → arrow::RecordBatch conversion. Also handle projections. ### Willingness to contribute - [ ] I'm willing to submit a PR! -- 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]
