Method CleanUpSinglePartition

be/src/exec/partitioned-hash-join-builder.cc:861–876

}

void PhjBuilder::CleanUpSinglePartition(
    deque<unique_ptr<PhjBuilderPartition>>* output_partitions, RowBatch* batch) {
  SCOPED_TIMER(profile()->total_time_counter());
  if (NeedToProcessUnmatchedBuildRows(join_op_)) {
    DCHECK_LE(num_probe_threads_, 1)
        << "Don't support returning build partitions with shared build";
    // If the build partition was in memory, we are done probing this partition.
    // In case of right-outer, right-anti and full-outer joins, we move this partition
    // to the list of partitions that we need to output their unmatched build rows.
    output_partitions->push_back(std::move(spilled_partitions_.back()));
  } else {
    // In any other case, just close the input build partition.
    spilled_partitions_.back()->Close(IsLeftSemiJoin(join_op_) ? nullptr : batch);
  }
  spilled_partitions_.pop_back();
}

Status PhjBuilder::BeginNullAwareProbe() {
  DCHECK(null_aware_partition_ != nullptr);