Struct parquet::file::serialized_reader::SerializedRowGroupReader
source · pub struct SerializedRowGroupReader<'a, R: ChunkReader> { /* private fields */ }Expand description
A serialized implementation for Parquet RowGroupReader.
Implementations§
source§impl<'a, R: ChunkReader> SerializedRowGroupReader<'a, R>
impl<'a, R: ChunkReader> SerializedRowGroupReader<'a, R>
sourcepub fn new(
chunk_reader: Arc<R>,
metadata: &'a RowGroupMetaData,
offset_index: Option<&'a [OffsetIndexMetaData]>,
props: ReaderPropertiesPtr,
) -> Result<Self>
pub fn new( chunk_reader: Arc<R>, metadata: &'a RowGroupMetaData, offset_index: Option<&'a [OffsetIndexMetaData]>, props: ReaderPropertiesPtr, ) -> Result<Self>
Creates new row group reader from a file, row group metadata and custom config.
Trait Implementations§
source§impl<R: 'static + ChunkReader> RowGroupReader for SerializedRowGroupReader<'_, R>
impl<R: 'static + ChunkReader> RowGroupReader for SerializedRowGroupReader<'_, R>
source§fn get_column_bloom_filter(&self, i: usize) -> Option<&Sbbf>
fn get_column_bloom_filter(&self, i: usize) -> Option<&Sbbf>
get bloom filter for the ith column
source§fn metadata(&self) -> &RowGroupMetaData
fn metadata(&self) -> &RowGroupMetaData
Get metadata information about this row group.
source§fn num_columns(&self) -> usize
fn num_columns(&self) -> usize
Get the total number of column chunks in this row group.
source§fn get_column_page_reader(&self, i: usize) -> Result<Box<dyn PageReader>>
fn get_column_page_reader(&self, i: usize) -> Result<Box<dyn PageReader>>
Get page reader for the
ith column chunk.source§fn get_row_iter(&self, projection: Option<SchemaType>) -> Result<RowIter<'_>>
fn get_row_iter(&self, projection: Option<SchemaType>) -> Result<RowIter<'_>>
source§fn get_column_reader(&self, i: usize) -> Result<ColumnReader>
fn get_column_reader(&self, i: usize) -> Result<ColumnReader>
Get value reader for the
ith column chunk.Auto Trait Implementations§
impl<'a, R> Freeze for SerializedRowGroupReader<'a, R>
impl<'a, R> RefUnwindSafe for SerializedRowGroupReader<'a, R>where
R: RefUnwindSafe,
impl<'a, R> Send for SerializedRowGroupReader<'a, R>
impl<'a, R> Sync for SerializedRowGroupReader<'a, R>
impl<'a, R> Unpin for SerializedRowGroupReader<'a, R>
impl<'a, R> UnwindSafe for SerializedRowGroupReader<'a, R>where
R: RefUnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more