Module reader_builder 

Re-exports

use crate::arrow::ProjectionMask; 🔒

use crate::arrow::array_reader::ArrayReaderBuilder; 🔒

use crate::arrow::array_reader::CacheOptions; 🔒

use crate::arrow::array_reader::RowGroupCache; 🔒

use crate::arrow::arrow_reader::metrics::ArrowReaderMetrics; 🔒

use crate::arrow::arrow_reader::selection::LoadedRowRanges; 🔒

use crate::arrow::arrow_reader::selection::RowSelectionStrategy; 🔒

use crate::arrow::arrow_reader::ParquetRecordBatchReader; 🔒

use crate::arrow::arrow_reader::PredicateOptions; 🔒

use crate::arrow::arrow_reader::ReadPlanBuilder; 🔒

use crate::arrow::arrow_reader::RowFilter; 🔒

use crate::arrow::arrow_reader::RowSelection; 🔒

use crate::arrow::arrow_reader::RowSelectionPolicy; 🔒

use crate::arrow::in_memory_row_group::ColumnChunkData; 🔒

use crate::arrow::push_decoder::reader_builder::data::DataRequestBuilder; 🔒

use crate::arrow::push_decoder::reader_builder::filter::CacheInfo; 🔒

use crate::arrow::push_decoder::scan_plan::BudgetedReadPlan; 🔒

use crate::arrow::push_decoder::scan_plan::RowBudget; 🔒

use crate::arrow::push_decoder::scan_plan::RowGroupFrontier; 🔒

use crate::arrow::push_decoder::scan_plan::ScanPlanBuilder; 🔒

use crate::arrow::schema::ParquetField; 🔒

use crate::errors::ParquetError; 🔒

use crate::file::metadata::page_index::RowGroupPageIndex; 🔒

use crate::file::metadata::ColumnChunkMetaData; 🔒

use crate::file::metadata::ParquetMetaData; 🔒

use crate::util::push_buffers::PushBuffers; 🔒

use bytes::Bytes; 🔒

use data::DataRequest; 🔒

use filter::AdvanceResult; 🔒

use filter::FilterInfo; 🔒

pub(crate) use stages::Stage; 🔒

pub(crate) use stages::StageSchedule; 🔒

use std::ops::Range; 🔒

use std::sync::Arc; 🔒

use std::sync::RwLock; 🔒

Modules

data 🔒

DataRequest tracks and holds data needed to construct InMemoryRowGroups

filter 🔒

FilterInfo state machine for evaluating row filters

stages 🔒

StageSchedule: what each decoding stage of a row group fetches.

Structs

NextState 🔒

Result of a state transition

RowGroupInfo 🔒

The current row group being read, its read plan, and its offset/limit budget.

RowGroupReaderBuilder 🔒

Builder for ParquetRecordBatchReader for a single row group

RowGroupReaderBuilderParts 🔒

The parts of a RowGroupReaderBuilder needed to rebuild it, recovered by RowGroupReaderBuilder::into_parts.

Enums

RowGroupBuildResult 🔒

RowGroupDecoderState 🔒

This is the inner state machine for reading a single row group.

Functions

column_chunk_range 🔒

The byte range of a column chunk in the file.

loaded_row_ranges_for_projection 🔒

Computes row ranges for which every projected column has page data loaded.

prepare_selection_for_page_skipping 🔒

Prepare row selection execution when page pruning produced sparse column data.