Method flush

bolt/exec/SpillFile.cpp:267–294

}

uint64_t SpillWriter::flush() {
  if (batch_ == nullptr) {
    return 0;
  }

  auto* file = ensureFile();
  BOLT_CHECK_NOT_NULL(file);

  IOBufOutputStream out(
      *pool_, nullptr, std::max<int64_t>(64 * 1024, batch_->size()));
  uint64_t flushTimeUs{0};
  {
    MicrosecondTimer timer(&flushTimeUs);
    batch_->flush(&out);
  }
  batch_.reset();

  uint64_t writeTimeUs{0};
  uint64_t writtenBytes{0};
  auto iobuf = out.getIOBuf();
  {
    MicrosecondTimer timer(&writeTimeUs);
    writtenBytes = file->write(std::move(iobuf));
  }
  updateWriteStats(writtenBytes, flushTimeUs, writeTimeUs);
  updateAndCheckSpillLimitCb_(writtenBytes);
  return writtenBytes;
}

uint64_t SpillWriter::write(
    const RowVectorPtr& rows,