Method combineWrappers

bolt/vector/DecodedVector.cpp:150–203

}

void DecodedVector::combineWrappers(
    const BaseVector* vector,
    const SelectivityVector* rows,
    int numLevels) {
  auto topEncoding = vector->encoding();
  BaseVector* values = nullptr;
  if (topEncoding == VectorEncoding::Simple::DICTIONARY) {
    indices_ = vector->wrapInfo()->as<vector_size_t>();
    values = vector->valueVector().get();
    nulls_ = vector->rawNulls();
    if (nulls_) {
      hasExtraNulls_ = true;
      mayHaveNulls_ = true;
    }
  } else {
    BOLT_FAIL(
        "Unsupported wrapper encoding: {}",
        VectorEncoding::mapSimpleToName(topEncoding));
  }
  int32_t levelCounter = 0;
  for (;;) {
    if (numLevels != -1 && ++levelCounter == numLevels) {
      baseVector_ = values;
      return;
    }

    auto encoding = values->encoding();
    if (isLazy(encoding) &&
        (loadLazy_ || values->asUnchecked<LazyVector>()->isLoaded())) {
      values = values->loadedVector();
      encoding = values->encoding();
    }

    switch (encoding) {
      case VectorEncoding::Simple::LAZY:
      case VectorEncoding::Simple::CONSTANT:
      case VectorEncoding::Simple::FLAT:
      case VectorEncoding::Simple::BIASED:
      case VectorEncoding::Simple::ROW:
      case VectorEncoding::Simple::VARIANT:
      case VectorEncoding::Simple::ARRAY:
      case VectorEncoding::Simple::MAP:
        setBaseData(*values, rows);
        return;
      case VectorEncoding::Simple::DICTIONARY: {
        applyDictionaryWrapper(*values, rows);
        values = values->valueVector().get();
        break;
      }
      default:
        BOLT_CHECK(false, "Unsupported vector encoding");
    }
  }
}

void DecodedVector::applyDictionaryWrapper(
    const BaseVector& dictionaryVector,