Struct parquet::arrow::arrow_reader::ParquetFileArrowReader
source · [−]pub struct ParquetFileArrowReader { /* private fields */ }
Implementations
sourceimpl ParquetFileArrowReader
impl ParquetFileArrowReader
pub fn new(file_reader: Arc<dyn FileReader>) -> Self
pub fn get_metadata(&mut self) -> ParquetMetaData
Trait Implementations
sourceimpl ArrowReader for ParquetFileArrowReader
impl ArrowReader for ParquetFileArrowReader
type RecordReader = ParquetRecordBatchReader
sourcefn get_schema(&mut self) -> Result<Schema>
fn get_schema(&mut self) -> Result<Schema>
Read parquet schema and convert it into arrow schema.
sourcefn get_schema_by_columns<T>(
&mut self,
column_indices: T,
leaf_columns: bool
) -> Result<Schema> where
T: IntoIterator<Item = usize>,
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
Read more
sourcefn get_record_reader(
&mut self,
batch_size: usize
) -> Result<ParquetRecordBatchReader>
fn get_record_reader(
&mut self,
batch_size: usize
) -> Result<ParquetRecordBatchReader>
Returns record batch reader from whole parquet file. Read more
sourcefn get_record_reader_by_columns<T>(
&mut self,
column_indices: T,
batch_size: usize
) -> Result<ParquetRecordBatchReader> where
T: IntoIterator<Item = usize>,
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
. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ParquetFileArrowReader
impl Send for ParquetFileArrowReader
impl Sync for ParquetFileArrowReader
impl Unpin for ParquetFileArrowReader
impl !UnwindSafe for ParquetFileArrowReader
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more