Method write

bolt/exec/SpillFile.cpp:171–185

}

uint64_t SpillWriteFile::write(std::unique_ptr<folly::IOBuf> iobuf) {
  auto writtenBytes = iobuf->computeChainDataLength();
  if (spillUringEnabled_ && file_->uringEnabled()) {
    while (iobuf) {
      auto current = std::move(iobuf);
      iobuf = current->pop();
      auto taskId = taskId_++;
      auto writeBuff = writeBuffers_->add(current, taskId, file_);
      file_->submitWrite(writeBuff, taskId);
    }
  } else {
    file_->append(std::move(iobuf));
  }
  return writtenBytes;
}

uint64_t SpillWriteFile::write(std::string_view buf) {
  auto writtenBytes = buf.size();