Trait datafusion::execution::datasource::DataSource

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

Required methods

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

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

Loading content...

Implementors

impl DataSource for CsvDataSource

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

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

Loading content...