Trait LazyBatchGenerator

Source
pub trait LazyBatchGenerator:
    Send
    + Sync
    + Debug
    + Display {
    // Required method
    fn generate_next_batch(&mut self) -> Result<Option<RecordBatch>>;
}

Required Methods§

Source

fn generate_next_batch(&mut self) -> Result<Option<RecordBatch>>

Generate the next batch, return None when no more batches are available

Implementors§