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.

ScanFingerprintBundle 🔒

Output of build_scan_fingerprint: the cache fingerprint plus the derived implied time range used to decide whether the cache key can drop the time predicates for a given partition (see build_range_cache_key).

ScanInput

Common input for different scanners.

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

build_scan_fingerprint 🔒

Builds a ScanFingerprintBundle from a ScanInput if the scan is eligible for partition range caching.

collect_json_nested_paths 🔒

file_in_range 🔒

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

narrow_read_columns_by_json_type_hint 🔒

pre_filter_mode 🔒