Method nextBatch

bolt/exec/SpillFile.cpp:632–644

}

bool SpillReadFile::nextBatch(RowVectorPtr& rowVector) {
  if (input_->atEnd()) {
    spillReadIOTimeUs_ = input_->getSpillReadIOTime();
    return false;
  }
  if (serde_ != nullptr) {
    serde_->deserialize(input_.get(), pool_, type_, &rowVector, &readOptions_);
  } else {
    VectorStreamGroup::read(
        input_.get(), pool_, type_, &rowVector, &readOptions_);
  }
  return true;
}

void SpillReadFile::reuse() {
  input_->reuse();