Method InputFinished

cpp/src/arrow/acero/hash_join_node.cc:928–941

  }

  Status InputFinished(ExecNode* input, int total_batches) override {
    ARROW_DCHECK(std::find(inputs_.begin(), inputs_.end(), input) != inputs_.end());
    size_t thread_index = plan_->query_context()->GetThreadIndex();
    int side = (input == inputs_[0]) ? 0 : 1;

    if (batch_count_[side].SetTotal(total_batches)) {
      if (side == 0) {
        return OnProbeSideFinished(thread_index);
      } else {
        return OnBuildSideFinished(thread_index);
      }
    }
    return Status::OK();
  }

  Status Init() override {
    QueryContext* ctx = plan_->query_context();