Method closeFile

bolt/exec/SpillFile.cpp:243–261

}

void SpillWriter::closeFile() {
  if (currentFile_ == nullptr) {
    return;
  }
  currentFile_->finish();
  updateSpilledFileStats(currentFile_->size());
  finishedFiles_.push_back(SpillFileInfo{
      .id = currentFile_->id(),
      .type = type_,
      .path = currentFile_->path(),
      .size = currentFile_->size(),
      .rowCount = rowsInCurrentFile_,
      .sortingKeys = sortingKeys_,
      .compressionKind = compressionKind_,
      .serdeKind = spillSerdeKind_,
      .rowInfo = rowInfo_});
  rowsInCurrentFile_ = 0;
  currentFile_.reset();
}

size_t SpillWriter::numFinishedFiles() const {
  return finishedFiles_.size();