Trait parquet::arrow::async_reader::AsyncFileReader
source · [−]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
sourcefn get_metadata(&mut self) -> BoxFuture<'_, Result<Arc<ParquetMetaData>>>
fn get_metadata(&mut self) -> BoxFuture<'_, Result<Arc<ParquetMetaData>>>
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
Trait Implementations
sourceimpl AsyncFileReader for Box<dyn AsyncFileReader>
impl AsyncFileReader for Box<dyn AsyncFileReader>
sourcefn get_bytes(&mut self, range: Range<usize>) -> BoxFuture<'_, Result<Bytes>>
fn get_bytes(&mut self, range: Range<usize>) -> BoxFuture<'_, Result<Bytes>>
Retrieve the bytes in range
sourcefn get_byte_ranges(
&mut self,
ranges: Vec<Range<usize>>
) -> BoxFuture<'_, Result<Vec<Bytes>>>
fn get_byte_ranges(
&mut self,
ranges: Vec<Range<usize>>
) -> BoxFuture<'_, Result<Vec<Bytes>>>
Retrieve multiple byte ranges. The default implementation will call get_bytes
sequentially
sourcefn get_metadata(&mut self) -> BoxFuture<'_, Result<Arc<ParquetMetaData>>>
fn get_metadata(&mut self) -> BoxFuture<'_, Result<Arc<ParquetMetaData>>>
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