You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@fluss.apache.org by "fresh-borzoni (via GitHub)" <gi...@apache.org> on 2026/02/14 01:35:50 UTC
[I] Core BatchScanner implementation [fluss-rust]
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: issues-unsubscribe@fluss.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Core BatchScanner implementation [fluss-rust]
Posted by "fresh-borzoni (via GitHub)" <gi...@apache.org>.
fresh-borzoni closed issue #316: Core BatchScanner implementation
URL: https://github.com/apache/fluss-rust/issues/316
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Core BatchScanner implementation [fluss-rust]
Posted by "fresh-borzoni (via GitHub)" <gi...@apache.org>.
fresh-borzoni commented on issue #316:
URL: https://github.com/apache/fluss-rust/issues/316#issuecomment-4178144434
@Arnav-panjla Are you still up to take the issue?
I've completed https://github.com/apache/fluss-rust/issues/315
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Core BatchScanner implementation [fluss-rust]
Posted by "fresh-borzoni (via GitHub)" <gi...@apache.org>.
fresh-borzoni commented on issue #316:
URL: https://github.com/apache/fluss-rust/issues/316#issuecomment-3901687983
@Arnav-panjla Thank you, but I believe this task is blocked by https://github.com/apache/fluss-rust/issues/315.
Maybe you shall collaborate with @zuston to split the work for this feature
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Core BatchScanner implementation [fluss-rust]
Posted by "Arnav-panjla (via GitHub)" <gi...@apache.org>.
Arnav-panjla commented on issue #316:
URL: https://github.com/apache/fluss-rust/issues/316#issuecomment-4178217561
yes sure, will take from here
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Core BatchScanner implementation [fluss-rust]
Posted by "Arnav-panjla (via GitHub)" <gi...@apache.org>.
Arnav-panjla commented on issue #316:
URL: https://github.com/apache/fluss-rust/issues/316#issuecomment-3901455430
Hi @fresh-borzoni
I’d like to take this on.
I’ve looked through the requirements and would be happy to implement it if it’s available.
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org