Module range_cache

Module range_cache 

Source
Expand description

Utilities for the partition range scan result cache.

StructsΒ§

CacheBatchBuffer πŸ”’
Buffers record batches for caching, tracking memory size while deduplicating shared dictionary values across batches.
PartitionRangeRowGroups πŸ”’
Row groups and whether all sources are file-only for a partition range.
RangeScanCacheKey πŸ”’
Cache key for range scan outputs.
RangeScanCacheValue πŸ”’
Cached result for one range scan.
ScanRequestFingerprint πŸ”’
Fingerprint of the scan request fields that affect partition range cache reuse.
ScanRequestFingerprintBuilder πŸ”’
SharedScanRequestFingerprint πŸ”’
Non-copiable struct of the fingerprint.

FunctionsΒ§

build_range_cache_key πŸ”’
Builds a cache key for the given partition range if it is eligible for caching.
cache_flat_range_stream πŸ”’
Wraps a stream to cache its output for future range cache hits.
cached_flat_range_stream πŸ”’
Returns a stream that replays cached record batches.
collect_partition_range_row_groups πŸ”’
Collects (file_id, row_group_index) pairs from a partition range’s row group indices.
pk_values_ptr_eq πŸ”’
Returns true if two primary key dictionary arrays share the same underlying values buffers by pointer comparison.
query_time_range_covers_partition_range πŸ”’