Method InputReceived

cpp/src/arrow/acero/asof_join_node.cc:1414–1437

  const Ordering& ordering() const override { return ordering_; }

  Status InputReceived(ExecNode* input, ExecBatch batch) override {
    // InputReceived may be called after execution was finished. Pushing it to the
    // InputState is unnecessary since we're done (and anyway may cause the
    // BackPressureController to pause the input, causing a deadlock), so drop it.
    if (::arrow::compute::kUnsequencedIndex == batch.index)
      return Status::Invalid("AsofJoin requires sequenced input");

    if (process_task_.is_finished()) {
      DEBUG_SYNC(this, "Input received while done. Short circuiting.",
                 DEBUG_MANIP(std::endl));
      return Status::OK();
    }

    // Get the input
    ARROW_DCHECK(std_has(inputs_, input));
    size_t k = std_find(inputs_, input) - inputs_.begin();

    // Put into the sequencing queue
    ARROW_RETURN_NOT_OK(state_.at(k)->InsertBatch(std::move(batch)));

    PushProcess(true);

    return Status::OK();
  }

  Status InputFinished(ExecNode* input, int total_batches) override {
    {