| 1400 | } |
| 1401 | |
| 1402 | bool Scheduler::IsCoordinatorOnlyQuery(const TQueryExecRequest& exec_request) { |
| 1403 | DCHECK_GT(exec_request.plan_exec_info.size(), 0); |
| 1404 | int64_t num_parallel_plans = exec_request.plan_exec_info.size(); |
| 1405 | const TPlanExecInfo& plan_exec_info = exec_request.plan_exec_info[0]; |
| 1406 | int64_t num_fragments = plan_exec_info.fragments.size(); |
| 1407 | DCHECK_GT(num_fragments, 0); |
| 1408 | auto type = plan_exec_info.fragments[0].partition.type; |
| 1409 | return num_parallel_plans == 1 && num_fragments == 1 |
| 1410 | && type == TPartitionType::UNPARTITIONED; |
| 1411 | } |
| 1412 | |
| 1413 | void Scheduler::PopulateFilepathToHostsMapping(const FInstanceScheduleState& finst, |
| 1414 | ScheduleState* state, ByNodeFilepathToHosts* duplicate_check) { |
no test coverage detected