mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-11 00:42:29 +00:00
Update StorageDistributed.cpp
This commit is contained in:
parent
866917ad32
commit
5cf9beabe3
@ -270,7 +270,8 @@ BlockInputStreams StorageDistributed::read(
|
|||||||
: ClusterProxy::SelectStreamFactory(
|
: ClusterProxy::SelectStreamFactory(
|
||||||
header, processed_stage, QualifiedTableName{remote_database, remote_table}, context.getExternalTables());
|
header, processed_stage, QualifiedTableName{remote_database, remote_table}, context.getExternalTables());
|
||||||
|
|
||||||
if (settings.distributed_optimize_skip_select_on_unused_shards) {
|
if (settings.distributed_optimize_skip_select_on_unused_shards)
|
||||||
|
{
|
||||||
auto optimizer = StorageDistributedShardsOptimizer();
|
auto optimizer = StorageDistributedShardsOptimizer();
|
||||||
auto smaller_cluster = optimizer.skipUnusedShards(cluster, query_info, sharding_key_expr, sharding_key_column_name);
|
auto smaller_cluster = optimizer.skipUnusedShards(cluster, query_info, sharding_key_expr, sharding_key_column_name);
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user