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 rows with a known schema)

Required methods

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

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

get the schema for this relation

Loading content...

Implementors

impl Relation for FilterRelation

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

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

impl Relation for ProjectRelation

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

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

impl Relation for DataSourceRelation

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

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

Loading content...