connectorx::arrow_batch_iter

Trait RecordBatchIterator

Source 
pub trait RecordBatchIterator: Send {
    // 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> + Send,