Method copySerializedRow

bolt/exec/RowContainer.cpp:762–795

}

void RowContainer::copySerializedRow(
    char* const serializedRow,
    RowFormatInfo* const info) {
  auto newRow = this->newRow();
  memcpy(newRow, serializedRow, info->fixRowSize);
  for (const auto& [isStr, rowColumn] : info->variableColumns) {
    if (RowContainer::isNullAt(serializedRow, rowColumn)) {
      continue;
    }
    if (isStr) {
      StringView& sv =
          *reinterpret_cast<StringView*>(serializedRow + rowColumn.offset());
      if (!sv.isInline()) {
        *(int32_t*)(newRow + rowSizeOffset_) += sv.size();
        ByteOutputStream stream(stringAllocator_.get(), false, false);
        const auto position = stringAllocator_->newWrite(stream);
        stream.appendStringView(sv);
        stringAllocator_->finishWrite(stream, 0);
        valueAt<StringView>(newRow, rowColumn.offset()) =
            StringView(reinterpret_cast<char*>(position.position), sv.size());
      }
    } else {
      auto& sv = *reinterpret_cast<std::string_view*>(
          serializedRow + rowColumn.offset());
      *(int32_t*)(newRow + rowSizeOffset_) += sv.size();
      ByteOutputStream stream(stringAllocator_.get(), false, false);
      const auto position = stringAllocator_->newWrite(stream);
      stream.appendStringView(sv);
      stringAllocator_->finishWrite(stream, 0);
      valueAt<std::string_view>(newRow, rowColumn.offset()) = std::string_view(
          reinterpret_cast<char*>(position.position), sv.size());
    }
  }
}

void RowContainer::storeSerializedRow(
    const FlatVector<StringView>& vector,