Method prepareForSpillRestore

bolt/exec/HashProbe.cpp:498–526

}

void HashProbe::prepareForSpillRestore() {
  checkRunning();
  BOLT_CHECK(spillEnabled());
  BOLT_CHECK(hasMoreSpillData());

  // Reset the internal states which are relevant to the previous probe run.
  noMoreSpillInput_ = false;
  table_.reset();
  spiller_.reset();
  if (!reuseSpillReader_) {
    spillInputReader_.reset();
  }
  spillInputPartitionIds_.clear();
  lastProbeIterator_.reset();

  BOLT_CHECK(promises_.empty() || lastProber_);
  if (!lastProber_) {
    return;
  }
  lastProber_ = false;
  // Notify the hash build operators to build the next hash table.
  joinBridge_->probeFinished();

  // Wake up the peer hash probe operators to wait for table build.
  auto promises = std::move(promises_);
  for (auto& promise : promises) {
    promise.setValue();
  }
}

void HashProbe::addSpillInput() {
  checkRunning();