Trait datafusion::datasource::datasource::TableProvider

pub trait TableProvider {
    fn schema(&self) -> SchemaRef;
    fn scan(
        &self, 
        projection: &Option<Vec<usize>>, 
        batch_size: usize
    ) -> Result<Vec<ScanResult>>;
}

Source table

Required methods

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

fn scan(
    &self,
    projection: &Option<Vec<usize>>,
    batch_size: usize
) -> Result<Vec<ScanResult>>

Perform a scan of a table and return a sequence of iterators over the data (one iterator per partition)

Loading content...

Implementors

impl TableProvider for CsvFile

fn schema(&self) -> SchemaRef

fn scan(
    &self,
    projection: &Option<Vec<usize>>,
    batch_size: usize
) -> Result<Vec<ScanResult>>

impl TableProvider for MemTable

fn schema(&self) -> SchemaRef

fn scan(
    &self,
    projection: &Option<Vec<usize>>,
    _batch_size: usize
) -> Result<Vec<ScanResult>>

impl TableProvider for ParquetTable

fn schema(&self) -> SchemaRef

Get the schema for this parquet file.

fn scan(
    &self,
    projection: &Option<Vec<usize>>,
    batch_size: usize
) -> Result<Vec<ScanResult>>

Scan the file(s), using the provided projection, and return one BatchIterator per partition.

Loading content...