Struct parquet::arrow::arrow_reader::ParquetFileArrowReader

pub struct ParquetFileArrowReader { /* fields omitted */ }

Implementations

impl ParquetFileArrowReader

pub fn new(file_reader: Arc<dyn FileReader>) -> Self

pub fn get_metadata(&mut self) -> ParquetMetaData

Trait Implementations

impl ArrowReader for ParquetFileArrowReader

type RecordReader = ParquetRecordBatchReader

fn get_schema(&mut self) -> Result<Schema>

Read parquet schema and convert it into arrow schema.

fn get_schema_by_columns<T>(
    &mut self,
    column_indices: T,
    leaf_columns: bool
) -> Result<Schema> where
    T: IntoIterator<Item = usize>, 

Read parquet schema and convert it into arrow schema. This schema only includes columns identified by column_indices. To select leaf columns (i.e. a.b.c instead of a), set leaf_columns = true

fn get_record_reader(
    &mut self,
    batch_size: usize
) -> Result<ParquetRecordBatchReader>

Returns record batch reader from whole parquet file.

fn get_record_reader_by_columns<T>(
    &mut self,
    column_indices: T,
    batch_size: usize
) -> Result<ParquetRecordBatchReader> where
    T: IntoIterator<Item = usize>, 

Returns record batch reader whose record batch contains columns identified by column_indices.