alloc(const size_t num_bytes) override | foreign_storage::ForeignStorageMgr | |
allocateTempBuffersForChunks(const std::set< ChunkKey > &chunk_keys) | foreign_storage::ForeignStorageMgr | protected |
CachingForeignStorageMgr(ForeignStorageCache *cache) | foreign_storage::CachingForeignStorageMgr | |
checkIfS3NeedsToBeEnabled(const ChunkKey &chunk_key) | foreign_storage::ForeignStorageMgr | protectedstatic |
checkpoint() override | foreign_storage::ForeignStorageMgr | |
checkpoint(const int db_id, const int tb_id) override | foreign_storage::ForeignStorageMgr | |
clearTable(const ChunkKey &table_key) | foreign_storage::CachingForeignStorageMgr | private |
clearTempChunkBufferMapEntriesForTable(const ChunkKey &table_key) | foreign_storage::ForeignStorageMgr | protected |
clearTempChunkBufferMapEntriesForTableUnlocked(const ChunkKey &table_key) | foreign_storage::ForeignStorageMgr | protected |
createBuffer(const ChunkKey &chunk_key, const size_t page_size, const size_t initial_size) override | foreign_storage::ForeignStorageMgr | |
createDataWrapperIfNotExists(const ChunkKey &chunk_key) override | foreign_storage::CachingForeignStorageMgr | virtual |
createDataWrapperUnlocked(int32_t db, int32_t tb) | foreign_storage::ForeignStorageMgr | protected |
data_wrapper_map_ | foreign_storage::ForeignStorageMgr | protected |
data_wrapper_mutex_ | foreign_storage::ForeignStorageMgr | mutableprotected |
deleteBuffer(const ChunkKey &chunk_key, const bool purge) override | foreign_storage::ForeignStorageMgr | |
deleteBuffersWithPrefix(const ChunkKey &chunk_key_prefix, const bool purge) override | foreign_storage::ForeignStorageMgr | |
disk_cache_ | foreign_storage::CachingForeignStorageMgr | private |
eraseDataWrapper(const ChunkKey &key) override | foreign_storage::CachingForeignStorageMgr | privatevirtual |
evictChunkFromCache(const ChunkKey &chunk_key) override | foreign_storage::CachingForeignStorageMgr | privatevirtual |
fetchBuffer(const ChunkKey &chunk_key, AbstractBuffer *destination_buffer, const size_t num_bytes) override | foreign_storage::CachingForeignStorageMgr | |
fetchBufferIfTempBufferMapEntryExists(const ChunkKey &chunk_key, AbstractBuffer *destination_buffer, const size_t num_bytes) | foreign_storage::ForeignStorageMgr | protected |
ForeignStorageMgr() | foreign_storage::ForeignStorageMgr | |
free(AbstractBuffer *buffer) override | foreign_storage::ForeignStorageMgr | |
getAllocated() override | foreign_storage::ForeignStorageMgr | |
getBuffer(const ChunkKey &chunk_key, const size_t num_bytes) override | foreign_storage::ForeignStorageMgr | |
getBufferSize(const ChunkKey &key) const | foreign_storage::CachingForeignStorageMgr | private |
getChunkMetadataVecForKeyPrefix(ChunkMetadataVector &chunk_metadata, const ChunkKey &chunk_key_prefix) override | foreign_storage::CachingForeignStorageMgr | |
getChunkMetadataVecFromDataWrapper(ChunkMetadataVector &chunk_metadata, const ChunkKey &chunk_key_prefix) | foreign_storage::CachingForeignStorageMgr | |
getDataWrapper(const ChunkKey &chunk_key) const | foreign_storage::ForeignStorageMgr | |
getHighestCachedFragId(const ChunkKey &table_key) | foreign_storage::CachingForeignStorageMgr | private |
getInUseSize() override | foreign_storage::ForeignStorageMgr | |
getMaxSize() override | foreign_storage::ForeignStorageMgr | |
getMgrType() override | foreign_storage::ForeignStorageMgr | |
getNumChunks() override | foreign_storage::ForeignStorageMgr | |
getOptionalChunkKeySetAndNormalizeCache(const ChunkKey &chunk_key, const std::set< ChunkKey > &required_chunk_keys, const ForeignDataWrapper::ParallelismLevel parallelism_level) | foreign_storage::ForeignStorageMgr | protected |
getOptionalKeysWithinSizeLimit(const ChunkKey &chunk_key, const std::set< ChunkKey, decltype(set_comp)* > &same_fragment_keys, const std::set< ChunkKey, decltype(set_comp)* > &diff_fragment_keys) const override | foreign_storage::CachingForeignStorageMgr | privatevirtual |
getPrefetchSets(const ChunkKey &chunk_key, const std::set< ChunkKey > &required_chunk_keys, const ForeignDataWrapper::ParallelismLevel parallelism_level) const | foreign_storage::ForeignStorageMgr | protected |
getRequiredBuffersSize(const ChunkKey &chunk_key) const | foreign_storage::CachingForeignStorageMgr | private |
getStringMgrType() override | foreign_storage::ForeignStorageMgr | |
hasDataWrapperForChunk(const ChunkKey &chunk_key) const | foreign_storage::ForeignStorageMgr | |
hasMaxFetchSize() const override | foreign_storage::CachingForeignStorageMgr | privatevirtual |
hasStoredDataWrapper(int32_t db, int32_t tb) const | foreign_storage::CachingForeignStorageMgr | |
isAllocationCapped() override | foreign_storage::ForeignStorageMgr | |
isBufferOnDevice(const ChunkKey &chunk_key) override | foreign_storage::ForeignStorageMgr | |
isChunkCached(const ChunkKey &chunk_key) const override | foreign_storage::CachingForeignStorageMgr | privatevirtual |
isDatawrapperRestored(const ChunkKey &chunk_key) | foreign_storage::ForeignStorageMgr | |
maxFetchSize(int32_t db_id) const override | foreign_storage::CachingForeignStorageMgr | privatevirtual |
mocked_wrapper_map_ | foreign_storage::ForeignStorageMgr | protected |
parallelism_hints_mutex_ | foreign_storage::ForeignStorageMgr | mutableprotected |
parallelism_hints_per_table_ | foreign_storage::ForeignStorageMgr | protected |
ParallelismHint typedef | foreign_storage::ForeignStorageMgr | |
populateChunkBuffersSafely(ForeignDataWrapper &data_wrapper, ChunkToBufferMap &required_buffers, ChunkToBufferMap &optional_buffers) | foreign_storage::CachingForeignStorageMgr | private |
printSlabs() override | foreign_storage::ForeignStorageMgr | |
putBuffer(const ChunkKey &chunk_key, AbstractBuffer *source_buffer, const size_t num_bytes) override | foreign_storage::ForeignStorageMgr | |
refreshAppendTableInCache(const ChunkKey &table_key, const std::vector< ChunkKey > &old_chunk_keys) | foreign_storage::CachingForeignStorageMgr | private |
refreshChunksInCacheByFragment(const std::vector< ChunkKey > &old_chunk_keys, int last_frag_id) | foreign_storage::CachingForeignStorageMgr | private |
refreshNonAppendTableInCache(const ChunkKey &table_key, const std::vector< ChunkKey > &old_chunk_keys) | foreign_storage::CachingForeignStorageMgr | private |
refreshTable(const ChunkKey &table_key, const bool evict_cached_entries) override | foreign_storage::CachingForeignStorageMgr | virtual |
refreshTableInCache(const ChunkKey &table_key) | foreign_storage::CachingForeignStorageMgr | private |
removeTableRelatedDS(const int db_id, const int table_id) override | foreign_storage::CachingForeignStorageMgr | |
setDataWrapper(const ChunkKey &table_key, std::shared_ptr< MockForeignDataWrapper > data_wrapper) | foreign_storage::ForeignStorageMgr | |
setParallelismHints(const std::map< ChunkKey, std::set< ParallelismHint >> &hints_per_table) | foreign_storage::ForeignStorageMgr | |
temp_chunk_buffer_map_ | foreign_storage::ForeignStorageMgr | protected |
temp_chunk_buffer_map_mutex_ | foreign_storage::ForeignStorageMgr | mutableprotected |
updateFragmenterMetadata(const ChunkToBufferMap &) const | foreign_storage::ForeignStorageMgr | protected |
~ForeignStorageMgr() override | foreign_storage::ForeignStorageMgr | inline |