Method reclaim

bolt/exec/HashJoinBridge.cpp:207–225

}

uint64_t HashJoinMemoryReclaimer::reclaim(
    memory::MemoryPool* pool,
    uint64_t targetBytes,
    uint64_t maxWaitMs,
    memory::MemoryReclaimer::Stats& stats) {
  uint64_t reclaimedBytes{0};
  pool->visitChildren([&](memory::MemoryPool* child) {
    BOLT_CHECK_EQ(child->kind(), memory::MemoryPool::Kind::kLeaf);
    // The hash probe operator do not support memory reclaim.
    if (!isHashBuildMemoryPool(*child)) {
      return true;
    }
    // We only need to reclaim from any one of the hash build operators
    // which will reclaim from all the peer hash build operators.
    reclaimedBytes = child->reclaim(targetBytes, maxWaitMs, stats);
    return false;
  });
  return reclaimedBytes;
}

bool isHashBuildMemoryPool(const memory::MemoryPool& pool) {
  return folly::StringPiece(pool.name()).endsWith("HashBuild");