Method storeComplexType

bolt/exec/RowContainer.cpp:842–880

}

void RowContainer::storeComplexType(
    const DecodedVector& decoded,
    vector_size_t index,
    bool isKey,
    char* row,
    int32_t offset,
    int32_t nullByte,
    uint8_t nullMask) {
  if (decoded.isNullAt(index)) {
    BOLT_DCHECK(nullMask);
    row[nullByte] |= nullMask;
    valueAt<std::string_view>(row, offset) = std::string_view();
    return;
  }
  // RowSizeTracker tracker(row[rowSizeOffset_], *stringAllocator_);
  ByteOutputStream stream(stringAllocator_.get(), false, false);
  auto position = stringAllocator_->newWrite(stream);
  ContainerRowSerdeOptions options{.isKey = isKey};
  ContainerRowSerde::serialize(
      *decoded.base(), decoded.index(index), stream, options);
  stringAllocator_->finishWrite(stream, 0);

  valueAt<std::string_view>(row, offset) = std::string_view(
      reinterpret_cast<char*>(position.position), stream.size());

  // TODO Fix ByteOutputStream::size() API. @oerling is looking into that.
  // Fix the 'size' of the std::string_view.
  // stream.size() is the capacity
  // stream.size() - stream.remainingSize() is the size of the data + size of
  // 'next' links (8 bytes per link).
  auto readStream = prepareRead(row, offset);
  const auto size = readStream->size();
  valueAt<std::string_view>(row, offset) =
      std::string_view(reinterpret_cast<char*>(position.position), size);

  auto value = *reinterpret_cast<uint32_t*>(row + rowSizeOffset_) + size;
  *reinterpret_cast<uint32_t*>(row + rowSizeOffset_) =
      std::min<uint64_t>(value, std::numeric_limits<uint32_t>::max());
}

//   static
int32_t RowContainer::compareStringAsc(