Module reader 

Parquet reader.

Modules

stream 🔒

Macros

handle_index_error 🔒

Structs

FlatRowGroupReader 🔒

Reader to read a row group of a parquet file in flat format, returning RecordBatch.

MetadataCacheMetrics

Metrics for parquet metadata cache operations.

ParquetReader

Parquet batch reader to read our SST format.

ParquetReaderBuilder

Parquet SST reader builder.

PhysicalFilterContext 🔒

Context to evaluate a physical expression for a parquet file.

ReaderFilterMetrics 🔒

Metrics of filtering rows groups and rows.

ReaderMetrics

Parquet reader metrics.

RowGroupBuildContext 🔒

Context passed to RowGroupReaderBuilder::build() carrying all information needed for prefiltering decisions.

RowGroupReaderBuilder 🔒

Builder to build a parquet record batch stream for a row group.

SimpleFilterContext 🔒

Context to evaluate the column filter for a parquet file.

Enums

MaybeFilter 🔒

The filter to evaluate or the prune result of the default value.

Constants

INDEX_TYPE_BLOOM 🔒

INDEX_TYPE_FULLTEXT 🔒

INDEX_TYPE_INVERTED 🔒

INDEX_TYPE_VECTOR 🔒

MAX_ROW_GROUPS_TO_CHECK_PK 🔒

Number of leading row groups sampled by should_read_pk_as_binary.

Functions

all_required_row_groups_searched 🔒

apply_selection_and_update_metrics 🔒

expr_is_immutable 🔒

has_row_level_selection 🔒

pruned_by_default 🔒

Prune a column by its default value. Returns false if we can’t create the default value or evaluate the filter.

should_read_pk_as_binary 🔒

Returns true if the __primary_key chunk in any of the first MAX_ROW_GROUPS_TO_CHECK_PK row groups exceeds the dictionary page size limit, signalling the writer likely fell back to plain encoding.

should_read_pk_as_binary_with_limit 🔒