dbms: added setting 'distributed_group_by_no_merge' [#METR-17060].

dbms/include/DB/Interpreters/Settings.h

@@ -100,6 +100,11 @@ struct Settings
 	/** Тихо пропускать недоступные шарды. */ \
 	M(SettingBool, skip_unavailable_shards, false) \
 	\
+	/** Не мерджить состояния агрегации с разных серверов при распределённой обработке запроса \
+	  *  - на случай, когда доподлинно известно, что на разных шардах разные ключи. \
+	  */ \
+	M(SettingBool, distributed_group_by_no_merge, false) \
+	\
 	/** Тонкие настройки для чтения из MergeTree */ \
 	\
 	/** Если из одного файла читается хотя бы столько строк, чтение можно распараллелить. */ \

dbms/src/Storages/StorageDistributed.cpp

@@ -154,7 +154,7 @@ BlockInputStreams StorageDistributed::read(
 
 	size_t result_size = (cluster.pools.size() * settings.max_parallel_replicas) + cluster.getLocalNodesNum();
 
-	processed_stage = result_size == 1
+	processed_stage = result_size == 1 || settings.distributed_group_by_no_merge
 		? QueryProcessingStage::Complete
 		: QueryProcessingStage::WithMergeableState;
 

dbms/tests/queries/0_stateless/00184_distributed_group_by_no_merge.reference

+1	1
+1	1

dbms/tests/queries/0_stateless/00184_distributed_group_by_no_merge.sql

+SELECT count(), uniq(dummy) FROM remote('127.0.0.{1,2}', system.one) SETTINGS distributed_group_by_no_merge = 1;