#include <ForeignStorageInterface.h>
|
| ForeignStorageBufferMgr (const int db_id, const int table_id, PersistentForeignStorageInterface *persistent_foreign_storage) |
|
void | checkpoint () override |
|
Data_Namespace::AbstractBuffer * | createBuffer (const ChunkKey &key, const size_t pageSize=0, const size_t initialSize=0) override |
|
Data_Namespace::AbstractBuffer * | getBuffer (const ChunkKey &key, const size_t numBytes=0) override |
|
void | fetchBuffer (const ChunkKey &key, Data_Namespace::AbstractBuffer *destBuffer, const size_t numBytes=0) override |
|
void | getChunkMetadataVecForKeyPrefix (ChunkMetadataVector &chunkMetadataVec, const ChunkKey &keyPrefix) override |
|
std::string | getStringMgrType () override |
|
size_t | getNumChunks () override |
|
void | deleteBuffer (const ChunkKey &key, const bool purge=true) override |
|
void | deleteBuffersWithPrefix (const ChunkKey &keyPrefix, const bool purge=true) override |
|
Data_Namespace::AbstractBuffer * | putBuffer (const ChunkKey &key, Data_Namespace::AbstractBuffer *srcBuffer, const size_t numBytes=0) override |
|
bool | isBufferOnDevice (const ChunkKey &key) override |
|
std::string | printSlabs () override |
|
void | clearSlabs () override |
|
size_t | getMaxSize () override |
|
size_t | getInUseSize () override |
|
size_t | getAllocated () override |
|
bool | isAllocationCapped () override |
|
void | checkpoint (const int db_id, const int tb_id) override |
|
Data_Namespace::AbstractBuffer * | alloc (const size_t numBytes=0) override |
|
void | free (Data_Namespace::AbstractBuffer *buffer) override |
|
MgrType | getMgrType () override |
|
void | removeTableRelatedDS (const int db_id, const int table_id) override |
|
Definition at line 117 of file ForeignStorageInterface.h.
void ForeignStorageBufferMgr::checkpoint |
( |
| ) |
|
|
override |
void ForeignStorageBufferMgr::checkpoint |
( |
const int |
db_id, |
|
|
const int |
tb_id |
|
) |
| |
|
inlineoverride |
void ForeignStorageBufferMgr::clearSlabs |
( |
| ) |
|
|
inlineoverride |
void ForeignStorageBufferMgr::deleteBuffer |
( |
const ChunkKey & |
key, |
|
|
const bool |
purge = true |
|
) |
| |
|
inlineoverride |
void ForeignStorageBufferMgr::deleteBuffersWithPrefix |
( |
const ChunkKey & |
keyPrefix, |
|
|
const bool |
purge = true |
|
) |
| |
|
inlineoverride |
size_t ForeignStorageBufferMgr::getAllocated |
( |
| ) |
|
|
inlineoverride |
Definition at line 107 of file ForeignStorageInterface.cpp.
References CHECK, chunk_index_, chunk_index_mutex_, and run_benchmark_import::type.
110 mapd_unique_lock<mapd_shared_mutex> chunk_index_write_lock(
119 std::search(chunk_it->first.begin(),
120 chunk_it->first.begin() + keyPrefix.size(),
122 keyPrefix.end()) != chunk_it->first.begin() + keyPrefix.size()) {
123 const auto& chunk_key = chunk_it->first;
124 if (chunk_key.size() == 5) {
125 if (chunk_key[4] == 1) {
126 const auto& buffer = *chunk_it->second;
127 auto type = buffer.getSqlType();
128 auto size = buffer.size();
129 auto subkey = chunk_key;
132 auto bs = index_buf.size() / index_buf.getSqlType().get_size();
133 auto chunk_metadata =
135 chunkMetadataVec.emplace_back(chunk_key, chunk_metadata);
138 const auto& buffer = *chunk_it->second;
139 auto chunk_metadata = std::make_shared<ChunkMetadata>();
140 chunk_metadata->sqlType = buffer.getSqlType();
141 buffer.getEncoder()->getMetadata(chunk_metadata);
142 chunkMetadataVec.emplace_back(chunk_key, chunk_metadata);
mapd_shared_mutex chunk_index_mutex_
std::map< ChunkKey, std::unique_ptr< ForeignStorageBuffer > > chunk_index_
size_t ForeignStorageBufferMgr::getInUseSize |
( |
| ) |
|
|
inlineoverride |
size_t ForeignStorageBufferMgr::getMaxSize |
( |
| ) |
|
|
inlineoverride |
MgrType ForeignStorageBufferMgr::getMgrType |
( |
| ) |
|
|
inlineoverride |
size_t ForeignStorageBufferMgr::getNumChunks |
( |
| ) |
|
|
inlineoverride |
std::string ForeignStorageBufferMgr::getStringMgrType |
( |
| ) |
|
|
inlineoverride |
bool ForeignStorageBufferMgr::isAllocationCapped |
( |
| ) |
|
|
inlineoverride |
bool ForeignStorageBufferMgr::isBufferOnDevice |
( |
const ChunkKey & |
key | ) |
|
|
inlineoverride |
std::string ForeignStorageBufferMgr::printSlabs |
( |
| ) |
|
|
inlineoverride |
void ForeignStorageBufferMgr::removeTableRelatedDS |
( |
const int |
db_id, |
|
|
const int |
table_id |
|
) |
| |
|
inlineoverride |
The documentation for this class was generated from the following files: