| 2688 | : gen_(std::move(gen)) {} |
| 2689 | |
| 2690 | Status Init(std::vector<std::string> columns, double scale_factor, int64_t batch_size, |
| 2691 | int64_t seed) override { |
| 2692 | seed_ = seed; |
| 2693 | scale_factor_ = scale_factor; |
| 2694 | batch_size_ = batch_size; |
| 2695 | ARROW_ASSIGN_OR_RAISE(schema_, gen_->SetPartOutputColumns(columns)); |
| 2696 | return Status::OK(); |
| 2697 | } |
| 2698 | |
| 2699 | Status StartProducing(size_t num_threads, OutputBatchCallback output_callback, |
| 2700 | FinishedCallback finished_callback, |
no test coverage detected