Struct SerializedFileReader

pub struct SerializedFileReader<R: ChunkReader> {
    chunk_reader: Arc<R>,
    metadata: Arc<ParquetMetaData>,
    props: ReaderPropertiesPtr,
}

A serialized implementation for Parquet FileReader.

Fields

chunk_reader: Arc<R>

metadata: Arc<ParquetMetaData>

props: ReaderPropertiesPtr

Implementations

impl<R: 'static + ChunkReader> SerializedFileReader<R>

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.

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

impl<R: 'static + ChunkReader> FileReader for SerializedFileReader<R>

fn metadata(&self) -> &ParquetMetaData

Get metadata information about this file.

fn num_row_groups(&self) -> usize

Get the total number of row groups for this file.

fn get_row_group(&self, i: usize) -> Result<Box<dyn RowGroupReader + '_>>

Get the ith row group reader. Note this doesn’t do bound check.

fn get_row_iter(&self, projection: Option<SchemaType>) -> Result<RowIter<'_>>

Get an iterator over the row in this file, see RowIter for caveats.

impl IntoIterator for SerializedFileReader<File>

Conversion into a RowIter using the full file schema over all row groups.

type Item = Result<Row, ParquetError>

The type of the elements being iterated over.

type IntoIter = RowIter<'static>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl TryFrom<&Path> for SerializedFileReader<File>

type Error = ParquetError

The type returned in the event of a conversion error.

fn try_from(path: &Path) -> Result<Self>

Performs the conversion.

impl TryFrom<&str> for SerializedFileReader<File>

type Error = ParquetError

The type returned in the event of a conversion error.

fn try_from(path: &str) -> Result<Self>

Performs the conversion.

impl TryFrom<File> for SerializedFileReader<File>

type Error = ParquetError

The type returned in the event of a conversion error.

fn try_from(file: File) -> Result<Self>

Performs the conversion.

impl TryFrom<String> for SerializedFileReader<File>

type Error = ParquetError

The type returned in the event of a conversion error.

fn try_from(path: String) -> Result<Self>

Performs the conversion.