| 8002 | } |
| 8003 | |
| 8004 | bool Context::canUseTaskBasedParallelReplicas() const |
| 8005 | { |
| 8006 | const auto & settings_ref = getSettingsRef(); |
| 8007 | |
| 8008 | if (!settings_ref[Setting::allow_experimental_analyzer] && settings_ref[Setting::parallel_replicas_only_with_analyzer]) |
| 8009 | return false; |
| 8010 | |
| 8011 | return settings_ref[Setting::allow_experimental_parallel_reading_from_replicas] > 0 |
| 8012 | && settings_ref[Setting::parallel_replicas_mode] == ParallelReplicasMode::READ_TASKS |
| 8013 | && (settings_ref[Setting::max_parallel_replicas] > 1 |
| 8014 | || !settings_ref[Setting::parallel_replicas_prefer_local_replica]) |
| 8015 | && settings_ref[Setting::automatic_parallel_replicas_mode] == 0; |
| 8016 | } |
| 8017 | |
| 8018 | bool Context::canUseParallelReplicasOnInitiator() const |
| 8019 | { |
no outgoing calls
no test coverage detected