Method storeVariableSizeAt

bolt/exec/RowContainer.cpp:637–669

}

int32_t RowContainer::storeVariableSizeAt(
    const char* data,
    char* row,
    column_index_t column) {
  const auto typeKind = typeKinds_[column];
  const auto rowColumn = rowColumns_[column];

  // First 4 bytes is the size of the data.
  const auto size = *reinterpret_cast<const int32_t*>(data);

  if (typeKind == TypeKind::VARCHAR || typeKind == TypeKind::VARBINARY) {
    valueAt<StringView>(row, rowColumn.offset()) = StringView(data + 4, size);
    if (size > 0) {
      stringAllocator_->copyMultipart(
          StringView(data + 4, size), row, rowColumn.offset());
    } else {
      valueAt<StringView>(row, rowColumn.offset()) = StringView();
    }
  } else {
    if (size > 0) {
      ByteOutputStream stream(stringAllocator_.get(), false, false);
      const auto position = stringAllocator_->newWrite(stream);
      stream.appendStringView(std::string_view(data + 4, size));
      stringAllocator_->finishWrite(stream, 0);
      valueAt<std::string_view>(row, rowColumn.offset()) =
          std::string_view(reinterpret_cast<char*>(position.position), size);
    } else {
      valueAt<std::string_view>(row, rowColumn.offset()) = std::string_view();
    }
  }

  return 4 + size;
}

void RowContainer::store(const RowVectorPtr& input) {
  BOLT_CHECK_EQ(input->childrenSize(), types_.size());