Method FinishedCallback

cpp/src/arrow/acero/hash_join_node.cc:1029–1035

  }

  Status FinishedCallback(int64_t total_num_batches) {
    bool expected = false;
    if (complete_.compare_exchange_strong(expected, true)) {
      return output_->InputFinished(this, static_cast<int>(total_num_batches));
    }
    return Status::OK();
  }

 private:
  AtomicCounter batch_count_[2];