Trait deltalake::datafusion::datasource::physical_plan::ParquetFileReaderFactory

source · 
pub trait ParquetFileReaderFactory: Debug + Send + Sync + 'static {
    // Required method
    fn create_reader(
        &self,
        partition_index: usize,
        file_meta: FileMeta,
        metadata_size_hint: Option<usize>,
        metrics: &ExecutionPlanMetricsSet
    ) -> Result<Box<dyn AsyncFileReader + Send>, DataFusionError>;
}
Expand description

Factory of parquet file readers.

Provides means to implement custom data access interface.

Required Methods§

source

fn create_reader( &self, partition_index: usize, file_meta: FileMeta, metadata_size_hint: Option<usize>, metrics: &ExecutionPlanMetricsSet ) -> Result<Box<dyn AsyncFileReader + Send>, DataFusionError>

Provides AsyncFileReader over parquet file specified in FileMeta

Implementors§