Struct parquet::file::serialized_reader::SerializedFileReader
source · pub struct SerializedFileReader<R: ChunkReader> { /* private fields */ }
Expand description
A serialized implementation for Parquet FileReader
.
Implementations§
source§impl<R: 'static + ChunkReader> SerializedFileReader<R>
impl<R: 'static + ChunkReader> SerializedFileReader<R>
sourcepub fn new(chunk_reader: R) -> Result<Self>
pub fn new(chunk_reader: R) -> Result<Self>
Creates file reader from a Parquet file. Returns error if Parquet file does not exist or is corrupt.
sourcepub fn new_with_options(chunk_reader: R, options: ReadOptions) -> Result<Self>
pub fn new_with_options(chunk_reader: R, options: ReadOptions) -> Result<Self>
Creates file reader from a Parquet file with read options. Returns error if Parquet file does not exist or is corrupt.
Trait Implementations§
source§impl<R: 'static + ChunkReader> FileReader for SerializedFileReader<R>
impl<R: 'static + ChunkReader> FileReader for SerializedFileReader<R>
source§fn metadata(&self) -> &ParquetMetaData
fn metadata(&self) -> &ParquetMetaData
Get metadata information about this file.
source§fn num_row_groups(&self) -> usize
fn num_row_groups(&self) -> usize
Get the total number of row groups for this file.
source§fn get_row_group(&self, i: usize) -> Result<Box<dyn RowGroupReader + '_>>
fn get_row_group(&self, i: usize) -> Result<Box<dyn RowGroupReader + '_>>
Get the
i
th row group reader. Note this doesn’t do bound check.source§fn get_row_iter(&self, projection: Option<SchemaType>) -> Result<RowIter<'_>>
fn get_row_iter(&self, projection: Option<SchemaType>) -> Result<RowIter<'_>>
source§impl IntoIterator for SerializedFileReader<File>
impl IntoIterator for SerializedFileReader<File>
Conversion into a RowIter
using the full file schema over all row groups.
Auto Trait Implementations§
impl<R> Freeze for SerializedFileReader<R>
impl<R> RefUnwindSafe for SerializedFileReader<R>where
R: RefUnwindSafe,
impl<R> Send for SerializedFileReader<R>
impl<R> Sync for SerializedFileReader<R>
impl<R> Unpin for SerializedFileReader<R>
impl<R> UnwindSafe for SerializedFileReader<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