Struct ParquetFileReader 

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

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

partitioned_file: PartitionedFile

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.

impl Drop for ParquetFileReader

fn drop(&mut self)

Executes the destructor for this type.