pub trait AsyncFileReader: Send {
    fn get_bytes(&mut self, range: Range<usize>) -> BoxFuture<'_, Result<Bytes>>;
    fn get_metadata(&mut self) -> BoxFuture<'_, Result<Arc<ParquetMetaData>>>;

    fn get_byte_ranges(
        &mut self,
        ranges: Vec<Range<usize>>
    ) -> BoxFuture<'_, Result<Vec<Bytes>>> { ... } }
Expand description

The asynchronous interface used by ParquetRecordBatchStream to read parquet files

Required Methods

Retrieve the bytes in range

Provides asynchronous access to the ParquetMetaData of a parquet file, allowing fine-grained control over how metadata is sourced, in particular allowing for caching, pre-fetching, catalog metadata, etc…

Provided Methods

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

Trait Implementations

Retrieve the bytes in range

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

Provides asynchronous access to the ParquetMetaData of a parquet file, allowing fine-grained control over how metadata is sourced, in particular allowing for caching, pre-fetching, catalog metadata, etc… Read more

Implementations on Foreign Types

Implementors