Struct BatchSource 

pub struct BatchSource<I> { /* private fields */ }

A RowSource over record batches that share a schema: the first batch’s schema is the source’s, and a later batch with different columns is an error.

Implementations

impl<I: Iterator<Item = RecordBatch>> BatchSource<I>

pub fn new(batches: impl IntoIterator<IntoIter = I>) -> Option<Self>

Read batches; None when there are none (no batch, no schema).

Trait Implementations

impl<I: Debug> Debug for BatchSource<I>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<I: Iterator<Item = RecordBatch>> RowSource for BatchSource<I>

fn columns(&self) -> &[String]

The column names, in order.

fn schema(&self) -> Option<&Schema>

What the source knows about the columns’ types, if anything. A source’s schema has one field per column, in the same order.

fn next_row(&mut self) -> Option<Result<Row, DataError>>

The next row, None at the end, or why it could not be read.

fn collect_rows(self) -> Result<Rows, DataError>

where Self: Sized,

Read every remaining row into memory.