Method StartProducing

cpp/src/arrow/acero/tpch_node.cc:2446–2459

  }

  Status StartProducing(size_t num_threads, OutputBatchCallback output_callback,
                        FinishedCallback finished_callback,
                        ScheduleCallback schedule_callback) override {
    thread_local_data_.resize(num_threads);
    for (ThreadLocalData& tld : thread_local_data_) tld.rng.seed(GetRandomSeed());

    output_callback_ = std::move(output_callback);
    finished_callback_ = std::move(finished_callback);
    schedule_callback_ = std::move(schedule_callback);
    for (size_t i = 0; i < num_threads; i++)
      RETURN_NOT_OK(schedule_callback_(
          [this](size_t thread_index) { return this->ProduceCallback(thread_index); }));
    return Status::OK();
  }

  std::shared_ptr<Schema> schema() const override { return schema_; }