Method ProbeQueuedBatches

cpp/src/arrow/acero/hash_join_node.cc:881–888

  }

  Status ProbeQueuedBatches(size_t thread_index) {
    {
      std::lock_guard<std::mutex> guard(probe_side_mutex_);
      queued_batches_to_probe_ = std::move(probe_accumulator_);
    }
    return plan_->query_context()->StartTaskGroup(task_group_probe_,
                                                  queued_batches_to_probe_.batch_count());
  }

  Status OnQueuedBatchesProbed(size_t thread_index) {
    queued_batches_to_probe_.Clear();