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§
sourcefn create_reader(
&self,
partition_index: usize,
file_meta: FileMeta,
metadata_size_hint: Option<usize>,
metrics: &ExecutionPlanMetricsSet
) -> Result<Box<dyn AsyncFileReader + Send>, DataFusionError>
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