pub trait LazyBatchGenerator:
Send
+ Sync
+ Debug
+ Display {
// Required method
fn generate_next_batch(&mut self) -> Result<Option<RecordBatch>>;
}Required Methods§
Sourcefn generate_next_batch(&mut self) -> Result<Option<RecordBatch>>
fn generate_next_batch(&mut self) -> Result<Option<RecordBatch>>
Generate the next batch, return None when no more batches are available