Trait datafusion::execution::relation::Relation

pub trait Relation {
    fn next(&mut self) -> Result<Option<RecordBatch>>;
    fn schema(&self) -> &Arc<Schema>;
}

trait for all relations (a relation is essentially just an iterator over batches of data, with a known schema)

Required methods

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

Get the next RecordBatch, or None if the iterator is exhausted

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

get the schema for this relation

Loading content...

Implementors

Loading content...