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

pub struct CsvExec { /* fields omitted */ }

Execution plan for scanning a CSV file

Methods

impl CsvExec

pub fn try_new(
    path: &str,
    schema: Arc<Schema>,
    has_header: bool,
    projection: Option<Vec<usize>>,
    batch_size: usize
) -> Result<Self>

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

Trait Implementations

impl ExecutionPlan for CsvExec

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

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.