Struct ParquetReader 

pub struct ParquetReader {
    pub filename: String,
    pub file_size: u64,
    pub pool: Pool<Postgres>,
    pub metadata_cache: Arc<MetadataCache>,
    pub inner: CachingReader,
}

A wrapper around a CachingReader that loads metadata on-demand using a shared global cache.

Fields

filename: String

file_size: u64

pool: Pool<Postgres>

metadata_cache: Arc<MetadataCache>

inner: CachingReader

Trait Implementations

impl AsyncFileReader for ParquetReader

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 + '_>>

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

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

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