Struct CacheManager

pub struct CacheManager {
    sst_meta_cache: Option<Cache<SstMetaKey, Arc<ParquetMetaData>>>,
    vector_cache: Option<Cache<(ConcreteDataType, Value), VectorRef>>,
    page_cache: Option<Cache<PageKey, Arc<PageValue>>>,
    write_cache: Option<Arc<WriteCache>>,
    index_cache: Option<Arc<IndexCache<FileId, InvertedIndexMetas>>>,
    bloom_filter_index_cache: Option<Arc<IndexCache<(FileId, ColumnId), BloomFilterMeta>>>,
    puffin_metadata_cache: Option<PuffinMetadataCacheRef>,
    selector_result_cache: Option<Cache<SelectorResultKey, Arc<SelectorResultValue>>>,
}

Manages cached data for the engine.

All caches are disabled by default.

Fields

sst_meta_cache: Option<Cache<SstMetaKey, Arc<ParquetMetaData>>>

Cache for SST metadata.

vector_cache: Option<Cache<(ConcreteDataType, Value), VectorRef>>

Cache for vectors.

page_cache: Option<Cache<PageKey, Arc<PageValue>>>

Cache for SST pages.

write_cache: Option<Arc<WriteCache>>

A Cache for writing files to object stores.

index_cache: Option<Arc<IndexCache<FileId, InvertedIndexMetas>>>

Cache for inverted index.

bloom_filter_index_cache: Option<Arc<IndexCache<(FileId, ColumnId), BloomFilterMeta>>>

Cache for bloom filter index.

puffin_metadata_cache: Option<PuffinMetadataCacheRef>

Puffin metadata cache.

selector_result_cache: Option<Cache<SelectorResultKey, Arc<SelectorResultValue>>>

Cache for time series selectors.

Implementations

impl CacheManager

pub fn builder() -> CacheManagerBuilder

Returns a builder to build the cache.

pub async fn get_parquet_meta_data( &self, region_id: RegionId, file_id: FileId, ) -> Option<Arc<ParquetMetaData>>

Gets cached [ParquetMetaData] from in-memory cache first. If not found, tries to get it from write cache and fill the in-memory cache.

pub fn get_parquet_meta_data_from_mem_cache( &self, region_id: RegionId, file_id: FileId, ) -> Option<Arc<ParquetMetaData>>

Gets cached [ParquetMetaData] from in-memory cache. This method does not perform I/O.

pub fn put_parquet_meta_data( &self, region_id: RegionId, file_id: FileId, metadata: Arc<ParquetMetaData>, )

Puts [ParquetMetaData] into the cache.

pub fn remove_parquet_meta_data(&self, region_id: RegionId, file_id: FileId)

Removes [ParquetMetaData] from the cache.

pub fn get_repeated_vector( &self, data_type: &ConcreteDataType, value: &Value, ) -> Option<VectorRef>

Gets a vector with repeated value for specific key.

pub fn put_repeated_vector(&self, value: Value, vector: VectorRef)

Puts a vector with repeated value into the cache.

pub fn get_pages(&self, page_key: &PageKey) -> Option<Arc<PageValue>>

Gets pages for the row group.

pub fn put_pages(&self, page_key: PageKey, pages: Arc<PageValue>)

Puts pages of the row group into the cache.

pub fn get_selector_result( &self, selector_key: &SelectorResultKey, ) -> Option<Arc<SelectorResultValue>>

Gets result of for the selector.

pub fn put_selector_result( &self, selector_key: SelectorResultKey, result: Arc<SelectorResultValue>, )

Puts result of the selector into the cache.

pub(crate) fn write_cache(&self) -> Option<&Arc<WriteCache>>

Gets the write cache.

pub(crate) fn inverted_index_cache( &self, ) -> Option<&Arc<IndexCache<FileId, InvertedIndexMetas>>>

pub(crate) fn bloom_filter_index_cache( &self, ) -> Option<&Arc<IndexCache<(FileId, ColumnId), BloomFilterMeta>>>

pub(crate) fn puffin_metadata_cache(&self) -> Option<&PuffinMetadataCacheRef>

Trait Implementations

impl Default for CacheManager

fn default() -> CacheManager

Returns the “default value” for a type.