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