Class ChunkMetadataRecycler

class ChunkMetadataRecycler : public DataRecycler<std::optional<ChunkMetadataMap>, ChunkMetadataMetaInfo>

Public Functions

ChunkMetadataRecycler()

numeric_limits()

numeric_limits()

std::optional<ChunkMetadataMap> getItemFromCache(QueryPlanHash key, CacheItemType item_type, DeviceIdentifier device_identifier, std::optional<ChunkMetadataMetaInfo> meta_info = std::nullopt)

void putItemToCache(QueryPlanHash key, std::optional<ChunkMetadataMap> item, CacheItemType item_type, DeviceIdentifier device_identifier, size_t item_size, size_t compute_time, std::optional<ChunkMetadataMetaInfo> meta_info = std::nullopt)

void initCache()

void clearCache()

void markCachedItemAsDirty(size_t table_key, std::unordered_set<QueryPlanHash> &key_set, CacheItemType item_type, DeviceIdentifier device_identifier)

std::string toString() const

void addQueryPlanDagForTableKeys(size_t hashed_query_plan_dag, const std::unordered_set<size_t> &table_keys, std::lock_guard<std::mutex> &lock)

std::optional<std::unordered_set<size_t>> getMappedQueryPlanDagsWithTableKey(size_t table_key) const

void removeTableKeyInfoFromQueryPlanDagMap(size_t table_key)

Private Functions

bool hasItemInCache(QueryPlanHash key, CacheItemType item_type, DeviceIdentifier device_identifier, std::lock_guard<std::mutex> &lock, std::optional<ChunkMetadataMetaInfo> meta_info = std::nullopt) const

void removeItemFromCache(QueryPlanHash key, CacheItemType item_type, DeviceIdentifier device_identifier, std::lock_guard<std::mutex> &lock, std::optional<ChunkMetadataMetaInfo> meta_info = std::nullopt)

void cleanupCacheForInsertion(CacheItemType item_type, DeviceIdentifier device_identifier, size_t required_size, std::lock_guard<std::mutex> &lock, std::optional<ChunkMetadataMetaInfo> meta_info = std::nullopt)

Private Members

std::unordered_map<size_t, std::unordered_set<size_t>> table_key_to_query_plan_dag_map_