| 3474 | } |
| 3475 | |
| 3476 | Result<ExecNode*> TpchGenImpl::Part(std::vector<std::string> columns) { |
| 3477 | if (!part_and_part_supp_generator_) { |
| 3478 | part_and_part_supp_generator_ = std::make_shared<PartAndPartSupplierGenerator>(); |
| 3479 | } |
| 3480 | std::unique_ptr<PartGenerator> generator = |
| 3481 | std::make_unique<PartGenerator>(part_and_part_supp_generator_); |
| 3482 | RETURN_NOT_OK(generator->Init(std::move(columns), scale_factor_, batch_size_, |
| 3483 | kSeedDist(seed_rng_))); |
| 3484 | return plan_->EmplaceNode<TpchNode>(plan_, "Part", std::move(generator)); |
| 3485 | } |
| 3486 | |
| 3487 | Result<ExecNode*> TpchGenImpl::PartSupp(std::vector<std::string> columns) { |
| 3488 | if (!part_and_part_supp_generator_) { |