Struct datafusion::datasource::csv::CsvFile

pub struct CsvFile { /* fields omitted */ }

Represents a CSV file with a provided schema

Implementations

impl CsvFile

pub fn try_new(path: &str, options: CsvReadOptions<'_>) -> Result<Self>

Attempt to initialize a new CsvFile from a file path

pub fn path(&self) -> &str

Get the path for the CSV file(s) represented by this CsvFile instance

pub fn has_header(&self) -> bool

Determine whether the CSV file(s) represented by this CsvFile instance have a header row

pub fn delimiter(&self) -> u8

Get the delimiter for the CSV file(s) represented by this CsvFile instance

pub fn file_extension(&self) -> &str

Get the file extension for the CSV file(s) represented by this CsvFile instance

Trait Implementations

impl TableProvider for CsvFile

fn as_any(&self) -> &dyn Any

Returns the table provider as Any so that it can be downcast to a specific implementation.

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

fn scan(
    &self,
    projection: &Option<Vec<usize>>,
    batch_size: usize,
    _filters: &[Expr],
    limit: Option<usize>
) -> Result<Arc<dyn ExecutionPlan>>

Create an ExecutionPlan that will scan the table.

fn statistics(&self) -> Statistics

Returns the table Statistics Statistics should be optional because not all data sources can provide statistics.

fn supports_filter_pushdown(
    &self,
    _filter: &Expr
) -> Result<TableProviderFilterPushDown>

Tests whether the table provider can make use of a filter expression to optimise data retrieval.