| 72 | SubarrayPartitioner::SubarrayPartitioner() = default; |
| 73 | |
| 74 | SubarrayPartitioner::SubarrayPartitioner( |
| 75 | const Config* const config, |
| 76 | const Subarray& subarray, |
| 77 | const uint64_t memory_budget, |
| 78 | const uint64_t memory_budget_var, |
| 79 | const uint64_t memory_budget_validity, |
| 80 | ThreadPool* const compute_tp, |
| 81 | Stats* const parent_stats, |
| 82 | shared_ptr<Logger> logger) |
| 83 | : stats_(parent_stats->create_child("SubarrayPartitioner")) |
| 84 | , logger_(logger->clone("SubarrayPartitioner", ++logger_id_)) |
| 85 | , config_(config) |
| 86 | , subarray_(subarray) |
| 87 | , memory_budget_(memory_budget) |
| 88 | , memory_budget_var_(memory_budget_var) |
| 89 | , memory_budget_validity_(memory_budget_validity) |
| 90 | , compute_tp_(compute_tp) { |
| 91 | state_.start_ = 0; |
| 92 | auto range_num = subarray_.range_num(); |
| 93 | state_.end_ = (range_num > 0) ? range_num - 1 : 0; |
| 94 | |
| 95 | skip_split_on_est_size_ = |
| 96 | config_->get<bool>("sm.skip_est_size_partitioning", Config::must_find); |
| 97 | |
| 98 | skip_unary_partitioning_budget_check_ = config_->get<bool>( |
| 99 | "sm.skip_unary_partitioning_budget_check", Config::must_find); |
| 100 | } |
| 101 | |
| 102 | SubarrayPartitioner::~SubarrayPartitioner() = default; |
| 103 |
nothing calls this directly
no test coverage detected