Struct CachedParquetFileReader 

pub struct CachedParquetFileReader {
    pub file_metrics: ParquetFileMetrics,
    store: Arc<dyn ObjectStore>,
    pub inner: ParquetObjectReader,
    partitioned_file: PartitionedFile,
    metadata_cache: Arc<dyn FileMetadataCache<Extra = ObjectMeta>>,
    metadata_size_hint: Option<usize>,
}

Implements [AsyncFileReader] for a Parquet file in object storage. Reads the file metadata from the FileMetadataCache, if available, otherwise reads it directly from the file and then updates the cache.

Fields

file_metrics: ParquetFileMetrics

store: Arc<dyn ObjectStore>

inner: ParquetObjectReader

partitioned_file: PartitionedFile

metadata_cache: Arc<dyn FileMetadataCache<Extra = ObjectMeta>>

metadata_size_hint: Option<usize>

Trait Implementations

impl AsyncFileReader for CachedParquetFileReader

fn get_bytes( &mut self, range: Range<u64>, ) -> Pin<Box<dyn Future<Output = Result<Bytes, ParquetError>> + Send + '_>>

Retrieve the bytes in range

fn get_byte_ranges( &mut self, ranges: Vec<Range<u64>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Bytes>, ParquetError>> + Send + '_>>

where CachedParquetFileReader: Send,

Retrieve multiple byte ranges. The default implementation will call get_bytes sequentially

fn get_metadata<'a>( &'a mut self, options: Option<&'a ArrowReaderOptions>, ) -> Pin<Box<dyn Future<Output = Result<Arc<ParquetMetaData>, ParquetError>> + Send + 'a>>

Return a future which results in the [ParquetMetaData] for this Parquet file.