Module opener 

ParquetOpener for opening Parquet files

Structs

EarlyStoppingStream 🔒

Wraps an inner RecordBatchStream and a [FilePruner]

EncryptionContext 🔒

ParquetOpener 🔒

Implements FileOpener for a parquet file

Functions

build_page_pruning_predicate 🔒

Build a page pruning predicate from an optional predicate expression. If the predicate is None or the predicate cannot be converted to a page pruning predicate, return None.

build_pruning_predicates 🔒

copy_arrow_reader_metrics 🔒

Copies metrics from ArrowReaderMetrics (the metrics collected by the arrow-rs parquet reader) to the parquet file metrics for DataFusion

create_initial_plan 🔒

Return the initial ParquetAccessPlan

load_page_index 🔒

Returns a ArrowReaderMetadata with the page index loaded, loading it from the underlying AsyncFileReader if necessary.

should_enable_page_index 🔒