| 2809 | class CustomerGenerator : public TpchTableGenerator { |
| 2810 | public: |
| 2811 | Status Init(std::vector<std::string> columns, double scale_factor, int64_t batch_size, |
| 2812 | int64_t seed) override { |
| 2813 | seed_ = seed; |
| 2814 | scale_factor_ = scale_factor; |
| 2815 | batch_size_ = batch_size; |
| 2816 | rows_to_generate_ = static_cast<int64_t>(scale_factor_ * 150000); |
| 2817 | rows_generated_.store(0); |
| 2818 | ARROW_ASSIGN_OR_RAISE(schema_, |
| 2819 | SetOutputColumns(columns, kTypes, kNameMap, gen_list_)); |
| 2820 | return Status::OK(); |
| 2821 | } |
| 2822 | |
| 2823 | Status StartProducing(size_t num_threads, OutputBatchCallback output_callback, |
| 2824 | FinishedCallback finished_callback, |
nothing calls this directly
no test coverage detected