Module scan_region 

Scans a region according to the scan request.

Structs

FileLevelPruningStats 🔒

Lightweight [PruningStatistics] that only uses the file-level time range from manifest metadata, avoiding any parquet metadata reads. Used for early file-level pruning before accessing row-group-level statistics.

PredicateGroup

Predicates to evaluate. It only keeps filters that SimpleFilterEvaluator supports.

ScanAnalysis 🔒

Cached output of scan request analysis: the optional range-cache fingerprint plus the derived implied time range used by range cache and prefilter.

ScanInput

Common input for different scanners.

ScanInputBuilder 🔒

Builder for a finalized ScanInput.

ScanRegion 🔒

Helper to scans a region by ScanRequest.

StreamContext

Context shared by different streams from a scanner. It contains the input and ranges to scan.

Enums

Scanner 🔒

A scanner scans a region and returns a SendableRecordBatchStream.

Functions

exact_sequence_range 🔒

Selects the SST files for a scan and, when requested, determines whether the selected files support an exact sequence-range scan.

file_in_range 🔒

Returns true if the time range of a SST file matches the predicate.

pre_filter_mode 🔒

time_range_covers_file 🔒

Returns true if time_range contains the inclusive time range of file.