| 131 | static const int MAX_BROADCAST_FILTER_PRODUCERS = 3; |
| 132 | |
| 133 | Coordinator::Coordinator(ClientRequestState* parent, const TExecRequest& exec_request, |
| 134 | const QuerySchedulePB& query_schedule, RuntimeProfile::EventSequence* events) |
| 135 | : parent_query_driver_(parent->parent_driver()), |
| 136 | parent_request_state_(parent), |
| 137 | exec_params_(exec_request, query_schedule), |
| 138 | filter_mode_(exec_params_.query_options().runtime_filter_mode), |
| 139 | obj_pool_(new ObjectPool()), |
| 140 | query_events_(events), |
| 141 | exec_rpcs_status_barrier_(query_schedule.backend_exec_params().size()), |
| 142 | backend_released_barrier_(query_schedule.backend_exec_params().size()), |
| 143 | filter_routing_table_(new FilterRoutingTable) {} |
| 144 | |
| 145 | Coordinator::~Coordinator() { |
| 146 | // Must have entered a terminal exec state guaranteeing resources were released. |
nothing calls this directly
no test coverage detected