24 using namespace Data_Namespace;
29 const std::string& data_dir,
30 const size_t num_reader_threads,
34 const size_t num_reader_threads,
38 const size_t page_size,
39 const size_t initial_size)
override;
40 void deleteBuffer(
const ChunkKey& chunk_key,
const bool purge)
override;
41 void deleteBuffersWithPrefix(
const ChunkKey& chunk_key_prefix,
42 const bool purge)
override;
44 void fetchBuffer(
const ChunkKey& chunk_key,
46 const size_t num_bytes)
override;
49 const size_t num_bytes)
override;
51 const ChunkKey& chunk_key_prefix)
override;
52 bool isBufferOnDevice(
const ChunkKey& chunk_key)
override;
53 std::string printSlabs()
override;
54 void clearSlabs()
override;
55 size_t getMaxSize()
override;
56 size_t getInUseSize()
override;
57 size_t getAllocated()
override;
58 bool isAllocationCapped()
override;
59 void checkpoint()
override;
60 void checkpoint(
const int db_id,
const int tb_id)
override;
63 MgrType getMgrType()
override;
64 std::string getStringMgrType()
override;
65 size_t getNumChunks()
override;
66 void removeTableRelatedDS(
const int db_id,
const int table_id)
override;
74 bool isForeignStorage(
const ChunkKey& chunk_key)
const;
75 AbstractBufferMgr* getStorageMgrForTableKey(
const ChunkKey& table_key)
const;
76 bool isChunkPrefixCacheable(
const ChunkKey& chunk_prefix)
const;
77 int recoverDataWrapperIfCachedAndGetHighestFragId(
const ChunkKey& table_key);
81 std::unique_ptr<foreign_storage::ForeignStorageCache>
disk_cache_;
std::vector< int > ChunkKey
const DiskCacheConfig getDiskCacheConfig() const
An AbstractBuffer is a unit of data management for a data manager.
std::unique_ptr< foreign_storage::ForeignStorageCache > disk_cache_
DiskCacheConfig disk_cache_config_
std::unique_ptr< File_Namespace::GlobalFileMgr > global_file_mgr_
std::unique_ptr< foreign_storage::ForeignStorageMgr > foreign_storage_mgr_