Method nextBatch

bolt/exec/Spill.cpp:353–367

}

void ConcatFilesSpillMergeStream::nextBatch() {
  BOLT_CHECK(!closed_);
  index_ = 0;
  for (; fileIndex_ < spillFiles_.size(); ++fileIndex_) {
    BOLT_CHECK_NOT_NULL(spillFiles_[fileIndex_]);
    if (spillFiles_[fileIndex_]->nextBatch(rowVector_)) {
      BOLT_CHECK_NOT_NULL(rowVector_);
      size_ = rowVector_->size();
      return;
    }
    spillFiles_[fileIndex_].reset();
  }
  size_ = 0;
  close();
}

void ConcatFilesSpillMergeStream::close() {
  BOLT_CHECK(!closed_);