Method claimLocalTable

src/processor/result/factorized_table_pool.cpp:6–16

namespace processor {

FactorizedTable* FactorizedTablePool::claimLocalTable(storage::MemoryManager* mm) {
    std::unique_lock<std::mutex> lck{mtx};
    if (availableLocalTables.empty()) {
        auto table = std::make_shared<FactorizedTable>(mm, globalTable->getTableSchema()->copy());
        localTables.push_back(table);
        availableLocalTables.push(table.get());
    }
    auto result = availableLocalTables.top();
    availableLocalTables.pop();
    return result;
}

void FactorizedTablePool::returnLocalTable(FactorizedTable* table) {
    std::unique_lock<std::mutex> lck{mtx};