pub struct DefaultParquetFileReaderFactory {
store: Arc<dyn ObjectStore>,
}Expand description
Default implementation of ParquetFileReaderFactory
This implementation:
- Reads parquet directly from an underlying [
ObjectStore] instance. - Reads the footer and page metadata on demand.
- Does not cache metadata or coalesce I/O operations.
Fields§
§store: Arc<dyn ObjectStore>Implementations§
Source§impl DefaultParquetFileReaderFactory
impl DefaultParquetFileReaderFactory
Sourcepub fn new(store: Arc<dyn ObjectStore>) -> DefaultParquetFileReaderFactory
pub fn new(store: Arc<dyn ObjectStore>) -> DefaultParquetFileReaderFactory
Create a new DefaultParquetFileReaderFactory.
Trait Implementations§
Source§impl ParquetFileReaderFactory for DefaultParquetFileReaderFactory
impl ParquetFileReaderFactory for DefaultParquetFileReaderFactory
Source§fn create_reader(
&self,
partition_index: usize,
partitioned_file: PartitionedFile,
metadata_size_hint: Option<usize>,
metrics: &ExecutionPlanMetricsSet,
) -> Result<Box<dyn AsyncFileReader + Send>, DataFusionError>
fn create_reader( &self, partition_index: usize, partitioned_file: PartitionedFile, metadata_size_hint: Option<usize>, metrics: &ExecutionPlanMetricsSet, ) -> Result<Box<dyn AsyncFileReader + Send>, DataFusionError>
Provides an
AsyncFileReader for reading data from a parquet file specified Read moreAuto Trait Implementations§
impl Freeze for DefaultParquetFileReaderFactory
impl !RefUnwindSafe for DefaultParquetFileReaderFactory
impl Send for DefaultParquetFileReaderFactory
impl Sync for DefaultParquetFileReaderFactory
impl Unpin for DefaultParquetFileReaderFactory
impl !UnwindSafe for DefaultParquetFileReaderFactory
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more