Function flattenArray

bolt/functions/lib/LambdaFunctionUtil.cpp:93–129

} // namespace

ArrayVectorPtr flattenArray(
    const SelectivityVector& rows,
    const VectorPtr& vector,
    DecodedVector& decodedVector) {
  if (decodedVector.isIdentityMapping()) {
    return std::dynamic_pointer_cast<ArrayVector>(vector);
  }

  auto newNumElements = countElements<ArrayVector>(rows, decodedVector);

  BufferPtr newNulls;
  BufferPtr elementIndices;
  BufferPtr newSizes;
  BufferPtr newOffsets;
  flattenBuffers<ArrayVector>(
      rows,
      newNumElements,
      decodedVector,
      newNulls,
      elementIndices,
      newSizes,
      newOffsets);

  auto array = decodedVector.base()->as<ArrayVector>();
  return std::make_shared<ArrayVector>(
      array->pool(),
      array->type(),
      newNulls,
      rows.end(),
      newOffsets,
      newSizes,
      BaseVector::wrapInDictionary(
          BufferPtr(nullptr),
          elementIndices,
          newNumElements,
          array->elements()));
}

MapVectorPtr flattenMap(
    const SelectivityVector& rows,