Struct ArrowFileReader

pub struct ArrowFileReader { /* private fields */ }

ArrowFileReader is a wrapper around a FileRead that impls parquets AsyncFileReader.

Implementations

impl ArrowFileReader

pub fn new(meta: FileMetadata, r: Box<dyn FileRead>) -> Self

Create a new ArrowFileReader

pub fn with_preload_column_index(self, preload: bool) -> Self

Enable or disable preloading of the column index

pub fn with_preload_offset_index(self, preload: bool) -> Self

Enable or disable preloading of the offset index

pub fn with_preload_page_index(self, preload: bool) -> Self

Enable or disable preloading of the page index

pub fn with_metadata_size_hint(self, hint: usize) -> Self

Provide a hint as to the number of bytes to prefetch for parsing the Parquet metadata

This hint can help reduce the number of fetch requests. For more details see the ParquetMetaDataReader documentation.

Trait Implementations

impl AsyncFileReader for ArrowFileReader

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

Retrieve the bytes in range

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

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

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