Module scan_region 

Scans a region according to the scan request.

Structs

ExplainString 🔒

Keeps the existing debug-list spacing while escaping strings as JSON, including control characters for which Rust’s Debug escaping is not valid JSON.

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.

FileSummary 🔒

Metadata totals for distinct SST files, not post-filter rows or actual read bytes. Older files may have unknown row and row-group counts represented by zero.

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.