Method OnProbeSideBatch

cpp/src/arrow/acero/hash_join_node.cc:823–842

  }

  Status OnProbeSideBatch(size_t thread_index, ExecBatch batch) {
    {
      std::lock_guard<std::mutex> guard(probe_side_mutex_);
      if (!bloom_filters_ready_) {
        probe_accumulator_.InsertBatch(std::move(batch));
        return Status::OK();
      }
    }
    RETURN_NOT_OK(pushdown_context_.FilterSingleBatch(thread_index, &batch));

    {
      std::lock_guard<std::mutex> guard(probe_side_mutex_);
      if (!hash_table_ready_) {
        probe_accumulator_.InsertBatch(std::move(batch));
        return Status::OK();
      }
    }
    RETURN_NOT_OK(impl_->ProbeSingleBatch(thread_index, std::move(batch)));
    return Status::OK();
  }

  Status OnProbeSideFinished(size_t thread_index) {
    bool probing_finished;