Trait LazyBatchGenerator 

pub trait LazyBatchGenerator:
    Send
    + Sync
    + Debug
    + Display {
    // Required methods
    fn as_any(&self) -> &dyn Any;
    fn generate_next_batch(&mut self) -> Result<Option<RecordBatch>>;

    // Provided method
    fn boundedness(&self) -> Boundedness { ... }
}

Required Methods

fn as_any(&self) -> &dyn Any

Returns the generator as Any so that it can be downcast to a specific implementation.

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

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

Provided Methods

fn boundedness(&self) -> Boundedness

Implementors