cosmetics

Author: filimonov

src/Storages/StorageDistributed.cpp

@@ -1211,6 +1211,7 @@ void StorageDistributed::read(
 
         // Create UnionStep to combine all plans
         auto union_step = std::make_unique<UnionStep>(std::move(headers), 0);
+        union_step->setStepDescription("TieredDistributedMerge");
 
         union_plan.unitePlans(std::move(union_step), std::move(plan_ptrs));
 
@@ -2197,6 +2198,12 @@ void StorageDistributed::delayInsertOrThrowIfNeeded() const
     }
 }
 
+void StorageDistributed::setAdditionalTableFunctions(std::vector<TableFunctionEntry> additional_table_functions_)
+{
+    additional_table_functions = std::move(additional_table_functions_);
+    log = getLogger("TieredDistributedMerge (" + getStorageID().table_name + ")");
+}
+
 void registerStorageDistributed(StorageFactory & factory)
 {
     factory.registerStorage("Distributed", [](const StorageFactory::Arguments & args)

src/Storages/StorageDistributed.h

@@ -175,10 +175,7 @@ class StorageDistributed final : public IStorage, WithContext
     void setAdditionalFilter(ASTPtr filter) { additional_filter = std::move(filter); }
 
     /// Set additional table functions for TieredDistributedMerge engine
-    void setAdditionalTableFunctions(std::vector<TableFunctionEntry> additional_table_functions_)
-    {
-        additional_table_functions = std::move(additional_table_functions_);
-    }
+    void setAdditionalTableFunctions(std::vector<TableFunctionEntry> additional_table_functions_);
 
     /// Getter methods for ClusterProxy::executeQuery
     StorageID getRemoteStorageID() const { return remote_storage; }