Closed
Description
Is your feature request related to a problem or challenge? Please describe what you are trying to do.
RecordBatchStream
represents an async stream of record batches, but currently it's only possible to iterate synchronously through each batch.
Describe the solution you'd like
Implement __anext__
as well as __next__
here, so it can be used as an asynchronous iterator from Python:
datafusion-python/src/record_batch.rs
Lines 57 to 64 in 5e97701
Describe alternatives you've considered
Additional context
This is similar to what I already have here wrapping ObjectStore::get