Method EndFromSingleThread

cpp/src/arrow/acero/asof_join_node.cc:1499–1510

  }

  void EndFromSingleThread(Status st = Status::OK()) {
    process_task_.MarkFinished(st);
    if (st.ok()) {
      st = output_->InputFinished(this, batches_produced_);
    }

    for (size_t i = 0; i < state_.size(); ++i) {
      const auto& s = state_[i];
      s->ForceShutdown();
      st &= inputs_[i]->StopProducing();
    }
  }

#endif