Trait connectorx::arrow_batch_iter::RecordBatchIterator

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

Required Methods§

source

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

source

fn prepare(&mut self)

source

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

Implementors§

source§

impl<'a, S, TP> RecordBatchIterator for ArrowBatchIter<S, TP>
where S: Source + 'a, TP: Transport<TSS = S::TypeSystem, TSD = ArrowStreamTypeSystem, S = S, D = ArrowStreamDestination>,