Method acquireSharedStringBuffers

bolt/vector/FlatVector.cpp:197–247

template <>
void FlatVector<StringView>::acquireSharedStringBuffers(
    const BaseVector* source) {
  if (!source) {
    return;
  }
  if (source->typeKind() != TypeKind::VARBINARY &&
      source->typeKind() != TypeKind::VARCHAR) {
    return;
  }
  auto bufferCount = stringBuffers_.size();
  source = source->wrappedVector();
  switch (source->encoding()) {
    case VectorEncoding::Simple::FLAT: {
      auto* flat = source->asUnchecked<FlatVector<StringView>>();
      for (auto& buffer : flat->stringBuffers_) {
        addStringBuffer(buffer);
      }
      break;
    }
    case VectorEncoding::Simple::CONSTANT: {
      if (!source->isNullAt(0)) {
        auto* constant = source->asUnchecked<ConstantVector<StringView>>();
        auto buffer = constant->getStringBuffer();
        if (buffer != nullptr) {
          addStringBuffer(buffer);
        }
      }
      break;
    }

    default:
      BOLT_UNREACHABLE(
          "unexpected encoding inside acquireSharedStringBuffers: {}",
          source->toString());
  }
  // if stringbuffers_.size() reach the integer multiple of logFreq, LOG the
  // memory information of this vector
  constexpr auto logFreq = 1024;
  if (stringBuffers_.size() / logFreq > bufferCount / logFreq) {
    uint64_t totalCapacity = 0, totalSize = 0;
    for (auto buffer : stringBuffers_) {
      totalSize += buffer->size();
      totalCapacity += buffer->capacity();
    }
    LOG(INFO) << "FlatVector string buffers count: " << stringBuffers_.size()
              << ", before acquire: " << bufferCount
              << ", totalSize: " << totalSize
              << ", totalCapacity: " << totalCapacity
              << ", pool name: " << pool_->name();
  }
}

template <>
void FlatVector<StringView>::acquireSharedStringBuffersRecursive(