Struct parquet::arrow::arrow_reader::ParquetFileArrowReader
source · pub struct ParquetFileArrowReader { /* private fields */ }
👎Deprecated: Use ParquetRecordBatchReaderBuilder instead
Expand description
An ArrowReader
that can be used to synchronously read parquet data as RecordBatch
See crate::arrow::async_reader
for an asynchronous interface
Implementations§
source§impl ParquetFileArrowReader
impl ParquetFileArrowReader
sourcepub fn try_new<R: ChunkReader + 'static>(chunk_reader: R) -> Result<Self>
pub fn try_new<R: ChunkReader + 'static>(chunk_reader: R) -> Result<Self>
Create a new ParquetFileArrowReader
with the provided ChunkReader
let file = File::open("file.parquet").unwrap();
let reader = ParquetFileArrowReader::try_new(file).unwrap();
let bytes = Bytes::from(vec![]);
let reader = ParquetFileArrowReader::try_new(bytes).unwrap();
sourcepub fn try_new_with_options<R: ChunkReader + 'static>(
chunk_reader: R,
options: ArrowReaderOptions
) -> Result<Self>
pub fn try_new_with_options<R: ChunkReader + 'static>(
chunk_reader: R,
options: ArrowReaderOptions
) -> Result<Self>
Create a new ParquetFileArrowReader
with the provided ChunkReader
and ArrowReaderOptions
sourcepub fn new(file_reader: Arc<dyn FileReader>) -> Self
pub fn new(file_reader: Arc<dyn FileReader>) -> Self
Create a new ParquetFileArrowReader
with the provided Arc<dyn FileReader>
sourcepub fn new_with_options(
file_reader: Arc<dyn FileReader>,
options: ArrowReaderOptions
) -> Self
pub fn new_with_options(
file_reader: Arc<dyn FileReader>,
options: ArrowReaderOptions
) -> Self
Create a new ParquetFileArrowReader
with the provided Arc<dyn FileReader>
and ArrowReaderOptions
sourcepub fn get_metadata(&mut self) -> ParquetMetaData
👎Deprecated: use metadata() instead
pub fn get_metadata(&mut self) -> ParquetMetaData
Expose the reader metadata
sourcepub fn metadata(&self) -> &ParquetMetaData
pub fn metadata(&self) -> &ParquetMetaData
Returns the parquet metadata
sourcepub fn parquet_schema(&self) -> &SchemaDescriptor
pub fn parquet_schema(&self) -> &SchemaDescriptor
Returns the parquet schema
Trait Implementations§
source§impl ArrowReader for ParquetFileArrowReader
impl ArrowReader for ParquetFileArrowReader
§type RecordReader = ParquetRecordBatchReader
type RecordReader = ParquetRecordBatchReader
👎Deprecated: Use ParquetRecordBatchReaderBuilder instead
source§fn get_schema(&mut self) -> Result<Schema>
fn get_schema(&mut self) -> Result<Schema>
👎Deprecated: Use ParquetRecordBatchReaderBuilder instead
Read parquet schema and convert it into arrow schema.
source§fn get_schema_by_columns(&mut self, mask: ProjectionMask) -> Result<Schema>
fn get_schema_by_columns(&mut self, mask: ProjectionMask) -> Result<Schema>
👎Deprecated: Use ParquetRecordBatchReaderBuilder instead
Read parquet schema and convert it into arrow schema.
This schema only includes columns identified by
mask
. Read moresource§fn get_record_reader(
&mut self,
batch_size: usize
) -> Result<ParquetRecordBatchReader>
fn get_record_reader(
&mut self,
batch_size: usize
) -> Result<ParquetRecordBatchReader>
👎Deprecated: Use ParquetRecordBatchReaderBuilder instead
Returns record batch reader from whole parquet file. Read more
source§fn get_record_reader_by_columns(
&mut self,
mask: ProjectionMask,
batch_size: usize
) -> Result<ParquetRecordBatchReader>
fn get_record_reader_by_columns(
&mut self,
mask: ProjectionMask,
batch_size: usize
) -> Result<ParquetRecordBatchReader>
👎Deprecated: Use ParquetRecordBatchReaderBuilder instead
Returns record batch reader whose record batch contains columns identified by
mask
. Read more