Struct datafusion::execution::physical_plan::csv::CsvExec

pub struct CsvExec { /* fields omitted */ }

Execution plan for scanning a CSV file

Implementations

impl CsvExec

pub fn try_new(
    path: &str,
    options: CsvReadOptions,
    projection: Option<Vec<usize>>,
    batch_size: usize
) -> Result<Self>

Create a new execution plan for reading a set of CSV files

pub fn try_infer_schema(path: &str, options: &CsvReadOptions) -> Result<Schema>

Infer schema for given CSV dataset

Trait Implementations

impl ExecutionPlan for CsvExec

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Get the partitions for this execution plan. Each partition can be executed in parallel.