Struct datafusion::datasource::parquet::ParquetTable

pub struct ParquetTable { /* fields omitted */ }

Table-based representation of a ParquetFile.

Implementations

impl ParquetTable

pub fn try_new(path: &str) -> Result<Self>

Attempt to initialize a new ParquetTable from a file path.

Trait Implementations

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<Arc<dyn ExecutionPlan>>

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