Method StartProducing

cpp/src/arrow/acero/tpch_node.cc:2699–2711

  }

  Status StartProducing(size_t num_threads, OutputBatchCallback output_callback,
                        FinishedCallback finished_callback,
                        ScheduleCallback schedule_callback) override {
    RETURN_NOT_OK(gen_->Init(num_threads, batch_size_, scale_factor_, seed_));
    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_; }