Struct ParquetFileReader 

pub struct ParquetFileReader {
    pub file_metrics: ParquetFileMetrics,
    pub inner: ParquetObjectReader,
}

Implements [AsyncFileReader] for a parquet file in object storage.

This implementation uses the [ParquetObjectReader] to read data from the object store on demand, as required, tracking the number of bytes read.

This implementation does not coalesce I/O operations or cache bytes. Such optimizations can be done either at the object store level or by providing a custom implementation of ParquetFileReaderFactory.

Fields

file_metrics: ParquetFileMetrics

inner: ParquetObjectReader

Trait Implementations

impl AsyncFileReader for ParquetFileReader

fn get_bytes(&mut self, range: Range<u64>) -> BoxFuture<'_, Result<Bytes>>

Retrieve the bytes in range

fn get_byte_ranges( &mut self, ranges: Vec<Range<u64>>, ) -> BoxFuture<'_, Result<Vec<Bytes>>>

where Self: Send,

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

fn get_metadata<'a>( &'a mut self, options: Option<&'a ArrowReaderOptions>, ) -> BoxFuture<'a, Result<Arc<ParquetMetaData>>>

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