Method InputFinished

cpp/src/arrow/acero/asof_join_node.cc:1439–1453

  }

  Status InputFinished(ExecNode* input, int total_batches) override {
    {
      std::lock_guard<std::mutex> guard(gate_);
      ARROW_DCHECK(std_has(inputs_, input));
      size_t k = std_find(inputs_, input) - inputs_.begin();
      state_.at(k)->set_total_batches(total_batches);
    }
    // Trigger a process call
    // The reason for this is that there are cases at the end of a table where we don't
    // know whether the RHS of the join is up-to-date until we know that the table is
    // finished.
    PushProcess(true);

    return Status::OK();
  }
  void PushProcess(bool value) {
#ifdef ARROW_ENABLE_THREADING
    process_.Push(value);