Method finishProbeInput

bolt/exec/NestedLoopJoinProbe.cpp:788–806

}

void NestedLoopJoinProbe::finishProbeInput() {
  BOLT_CHECK_NOT_NULL(input_);
  input_.reset();
  buildIndex_ = 0;
  probeRow_ = 0;

  if (!noMoreInput_) {
    return;
  }

  // From now one we finished processing the probe side. Check now if this is a
  // right or full outer join, and hence we may need to start emitting build
  // mismatch records.
  if (!needsBuildMismatch(joinType_) || isBuildSideEmpty()) {
    setState(ProbeOperatorState::kFinish);
    return;
  }
  beginBuildMismatch();
}

void NestedLoopJoinProbe::beginBuildMismatch() {
  BOLT_CHECK(needsBuildMismatch(joinType_));