Skip to main content

Module cache

Module cache 

Source
Expand description

Cache for the engine.

ModulesΒ§

cache_size πŸ”’
Cache size of different cache value.
file_cache πŸ”’
A cache for files.
index πŸ”’
manifest_cache πŸ”’
A cache for manifest files.
parquet_page πŸ”’
Fixed byte blocks shared across row groups of an immutable Parquet file.
range_cache πŸ”’
Coordinates range-result cache loads and SST retirement. No I/O or decoding runs under the coordinator lock; loaders use the shared query runtime.
write_cache πŸ”’
A write-through cache for remote object stores.

StructsΒ§

CacheManager
Manages cached data for the engine.
CacheManagerBuilder
Builder to construct a CacheManager.
CachedSstMeta πŸ”’
Cached SST metadata combines the parquet footer with the decoded region metadata.
CompactSstMeta πŸ”’
Compact, authoritative form of one SST’s metadata.
PrefilterKey πŸ”’
Key for a cached prefilter result.
PrefilterRowSelector πŸ”’
PreparedSstMeta πŸ”’
Both forms produced by decoding metadata after a cache miss.
RangeResultMemoryLimiter πŸ”’
SelectorResultKey
Cache key for time series row selector result.
SelectorResultValue
Cached result for time series row selector.
SstDecodedMetaKey πŸ”’
Separates loads that require different page-index guarantees.
SstMetaKey πŸ”’
Cache key (region id, file id) for SST meta.
SstMetaLoadError πŸ”’
SstMetaLoadResult πŸ”’
Metadata returned by a shared load. Cache hits ignore the original load’s miss flag.
SstMetaResolution πŸ”’
Resolved cache source, not physical I/O. Also returned when the subsequent load fails. A caller that observed a memory miss can find a completed value at the native recheck; it reuses that value’s source without executing its initializer. This does not prove that the caller waited for an in-flight load or performed a file-cache lookup. Ordinary memory hits return before this resolution is applied. A default value means no file-cache resolution was needed (or known).

EnumsΒ§

CacheStrategy
Cache strategies that may only enable a subset of caches.
SelectorResult
Result stored in the selector result cache.
SstMetaObservation πŸ”’
A caller’s memory observation. Holding the entry avoids a second lookup after coordination.
SstMetaPreparation πŸ”’
Result of decoding SST metadata and attempting to encode its compact cache entry.

ConstantsΒ§

FILE_TYPE πŸ”’
Metrics type key for files on the local store.
INDEX_TYPE πŸ”’
Metrics type key for index files (puffin) on the local store.
PREFILTER_RESULT_TYPE πŸ”’
Metrics type key for prefilter result cache.
RANGE_RESULT_CONCAT_MEMORY_LIMIT πŸ”’
RANGE_RESULT_CONCAT_MEMORY_PERMIT πŸ”’
RANGE_RESULT_TYPE πŸ”’
Metrics type key for range scan result cache.
SELECTOR_RESULT_TYPE πŸ”’
Metrics type key for selector result cache.
SST_META_DECODED_TYPE πŸ”’
Metrics type key for the optional decoded SST metadata acceleration tier.
SST_META_TYPE πŸ”’
Metrics type key for sst meta.
VECTOR_TYPE πŸ”’
Metrics type key for vector.

TraitsΒ§

WriteCacheUploadStoreWrapper
Wraps the remote object store used by write cache uploads.

FunctionsΒ§

decode_sst_meta πŸ”’
Decodes SST metadata on the given blocking runtime without preparing a compact cache entry.
decoded_meta_cache_weight πŸ”’
encode_compact_sst_meta πŸ”’
find_shared_page_source πŸ”’
Finds a typed shared error through the range-reader I/O wrappers.
finish_sst_meta_preparation πŸ”’
infer_loaded_page_index_policy πŸ”’
meta_cache_weight πŸ”’
new_prefilter_result_cache πŸ”’
prefilter_result_cache_weight πŸ”’
prepare_sst_meta πŸ”’
Decodes SST metadata and attempts to encode both cache representations on the given blocking runtime.
prepare_sst_meta_sync πŸ”’
Synchronously prepares SST metadata. Callers must run this on a blocking runtime.
range_result_cache_weight πŸ”’
removal_cause_str πŸ”’
satisfies_page_index_policy πŸ”’
selector_result_cache_hit
Increases selector cache hit metrics.
selector_result_cache_miss
Increases selector cache miss metrics.
selector_result_cache_weight πŸ”’
strip_column_indexes πŸ”’
strip_region_metadata_from_parquet πŸ”’
update_hit_miss πŸ”’
Updates cache hit/miss metrics.
vector_cache_weight πŸ”’

Type AliasesΒ§

CacheManagerRef
PrefilterResultCache πŸ”’
RangeResultCacheRef πŸ”’
Maps partition-range scan key to cached flat batches.
SelectorResultCache πŸ”’
Maps (file id, row group id, time series row selector) to SelectorResultValue.
SstDecodedMetaCache πŸ”’
Maps (region id, file id) to decoded SST metadata retained as an acceleration tier.
SstMetaCache πŸ”’
Maps (region id, file id) to compact SST metadata.
VectorCache πŸ”’
Maps [Value] to a vector that holds this value repeatedly.
WriteCacheUploadStoreWrapperRef