fresh-borzoni commented on issue #406: URL: https://github.com/apache/fluss-rust/issues/406#issuecomment-3980349918
@charlesdong1991 Shall we start first from Rust SDK? Otherwise all the clients would reimplement the same I see it like this: 1. Rust core: ScanBatchReader struct - wraps the poll loop, implements arrow::record_batch::RecordBatchReader (Iterator + schema). One place for the poll-filter-slice-stop logic. 2. Python: thin wrapper - constructs ScanBatchReader, calls next() in a generator, returns pa.RecordBatchReader.from_batches(schema, generator). 3. C++: same thin wrapper -- 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]
