Trait RecordBatchIterator 

pub trait RecordBatchIterator: Send {
    // Required methods
    fn get_schema(&self) -> (RecordBatch, &[String]);
    fn prepare(&mut self);
    fn next_batch(&mut self) -> Option<OutResult<RecordBatch>>;
}

Required Methods

fn get_schema(&self) -> (RecordBatch, &[String])

fn prepare(&mut self)

fn next_batch(&mut self) -> Option<OutResult<RecordBatch>>

See ArrowBatchIter::next for the error semantics.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<S, TP> RecordBatchIterator for ArrowBatchIter<S, TP>

where S: Source, TP: Transport<TSS = S::TypeSystem, TSD = ArrowStreamTypeSystem, S = S, D = ArrowStreamDestination> + Send, ConnectorXOutError: From<TP::Error>,