dqrun: add --exclude-linked-udfs option

Same as kqprun option added by ydb-platform#3150

Author: yumkam

ydb/library/yql/tools/dqrun/dqrun.cpp

@@ -13,6 +13,8 @@
 #include <ydb/library/yql/providers/yt/lib/config_clusters/config_clusters.h>
 #include <ydb/library/yql/providers/dq/local_gateway/yql_dq_gateway_local.h>
 
+#include <ydb/library/yql/public/udf/udf_static_registry.h>
+
 #include <ydb/library/yql/utils/log/proto/logger_config.pb.h>
 #include <ydb/library/yql/core/url_preprocessing/url_preprocessing.h>
 #include <ydb/library/yql/utils/actor_system/manager.h>
@@ -465,6 +467,7 @@ int RunMain(int argc, const char* argv[])
     TString fileStorageCfg;
     TVector<TString> udfsPaths;
     TString udfsDir;
+    bool excludeLinkedUdfs = false;
     TMaybe<TString> dqHost;
     TMaybe<int> dqPort;
     int threads = 16;
@@ -548,6 +551,11 @@ int RunMain(int argc, const char* argv[])
     opts.AddLongOption("udfs-dir", "Load all shared libraries with UDFs found"
                                    " in given directory")
         .StoreResult(&udfsDir);
+    opts.AddLongOption("exclude-linked-udfs", "Exclude linked udfs when same udf passed from -u or --udfs-dir")
+        .Optional()
+        .NoArgument()
+        .DefaultValue(excludeLinkedUdfs)
+        .SetFlag(&excludeLinkedUdfs);
     opts.AddLongOption("validate", "validate expression")
         .Optional()
         .NoArgument()
@@ -797,7 +805,16 @@ int RunMain(int argc, const char* argv[])
 
     NMiniKQL::FindUdfsInDir(udfsDir, &udfsPaths);
     auto funcRegistry = NMiniKQL::CreateFunctionRegistry(&NYql::NBacktrace::KikimrBackTrace, NMiniKQL::CreateBuiltinRegistry(), false, udfsPaths)->Clone();
-    NKikimr::NMiniKQL::FillStaticModules(*funcRegistry);
+    if (excludeLinkedUdfs) {
+        for (const auto& wrapper : NYql::NUdf::GetStaticUdfModuleWrapperList()) {
+            auto [name, ptr] = wrapper();
+            if (!funcRegistry->IsLoadedUdfModule(name)) {
+                funcRegistry->AddModule(TString(NKikimr::NMiniKQL::StaticModulePrefix) + name, name, std::move(ptr));
+            }
+        }
+    } else {
+        NKikimr::NMiniKQL::FillStaticModules(*funcRegistry);
+    }
 
     TGatewaysConfig gatewaysConfig;
     ReadGatewaysConfig(gatewaysCfgFile, &gatewaysConfig, sqlFlags);