diff options
author | vvvv <[email protected]> | 2025-04-21 20:53:56 +0300 |
---|---|---|
committer | vvvv <[email protected]> | 2025-04-21 21:26:59 +0300 |
commit | 108c1aa409626aa29ca728edafd01fbbd7a1b00e (patch) | |
tree | b88c1e3b690a29b0ed4f505f05990d656d6373ec /yql/essentials/tools/udf_resolver | |
parent | 6b17ad8c52e16d0088291781e1b5a9e28d028b9b (diff) |
YQL-19861 abi, udf resolvers, test, pass via yt gateways
commit_hash:6e3f5fac6a8598586987b52d749644d1ce1fccbe
Diffstat (limited to 'yql/essentials/tools/udf_resolver')
-rw-r--r-- | yql/essentials/tools/udf_resolver/discover.cpp | 5 | ||||
-rw-r--r-- | yql/essentials/tools/udf_resolver/discover.h | 6 | ||||
-rw-r--r-- | yql/essentials/tools/udf_resolver/udf_resolver.cpp | 2 | ||||
-rw-r--r-- | yql/essentials/tools/udf_resolver/ya.make | 1 |
4 files changed, 9 insertions, 5 deletions
diff --git a/yql/essentials/tools/udf_resolver/discover.cpp b/yql/essentials/tools/udf_resolver/discover.cpp index a290917a5a9..530e7d96e98 100644 --- a/yql/essentials/tools/udf_resolver/discover.cpp +++ b/yql/essentials/tools/udf_resolver/discover.cpp @@ -66,7 +66,7 @@ NYql::TResolveResult DoDiscover(const NYql::TResolve& inMsg, IMutableFunctionReg TFunctionTypeInfo funcInfo; if (!f.second.IsTypeAwareness) { - auto status = functionRegistry.FindFunctionTypeInfo(env, typeInfoHelper, + auto status = functionRegistry.FindFunctionTypeInfo(NYql::UnknownLangVersion, env, typeInfoHelper, nullptr, funcName, nullptr, nullptr, NUdf::IUdfModule::TFlags::TypesOnly, {}, nullptr, logProvider.Get(), &funcInfo); if (!status.IsOk()) { @@ -103,7 +103,8 @@ void Print(const NYql::TResolveResult& result, IOutputStream& out, bool printAsP out << "UDF count: " << result.UdfsSize() << Endl; } -void DiscoverInFiles(const TVector<TString>& udfPaths, IOutputStream& out, bool printAsProto, NYql::NUdf::ELogLevel logLevel) { +void DiscoverInFiles(const TVector<TString>& udfPaths, IOutputStream& out, bool printAsProto, + NYql::NUdf::ELogLevel logLevel) { NYql::TResolve inMsg; inMsg.SetRuntimeLogLevel(static_cast<ui32>(logLevel)); for (auto& path : udfPaths) { diff --git a/yql/essentials/tools/udf_resolver/discover.h b/yql/essentials/tools/udf_resolver/discover.h index 7c995b7f656..d32d3fa5a5a 100644 --- a/yql/essentials/tools/udf_resolver/discover.h +++ b/yql/essentials/tools/udf_resolver/discover.h @@ -9,8 +9,10 @@ #include <util/stream/output.h> namespace NUdfResolver { -void DiscoverInDir(const TString& dir, IOutputStream& out, bool printAsProto, NYql::NUdf::ELogLevel logLevel); -void DiscoverInFile(const TString& filePath, IOutputStream& out, bool printAsProto, NYql::NUdf::ELogLevel logLevel); +void DiscoverInDir(const TString& dir, IOutputStream& out, bool printAsProto, + NYql::NUdf::ELogLevel logLevel); +void DiscoverInFile(const TString& filePath, IOutputStream& out, bool printAsProto, + NYql::NUdf::ELogLevel logLevel); void Discover(IInputStream& in, IOutputStream& out, bool printAsProto); void FillImportResultModules(const THashSet<TString>& modules, NYql::TImportResult& importRes); ; diff --git a/yql/essentials/tools/udf_resolver/udf_resolver.cpp b/yql/essentials/tools/udf_resolver/udf_resolver.cpp index 27ab6f87d48..03116858f7e 100644 --- a/yql/essentials/tools/udf_resolver/udf_resolver.cpp +++ b/yql/essentials/tools/udf_resolver/udf_resolver.cpp @@ -174,7 +174,7 @@ void ResolveUDFs() { } TFunctionTypeInfo funcInfo; - auto status = newRegistry->FindFunctionTypeInfo(env, typeInfoHelper, nullptr, + auto status = newRegistry->FindFunctionTypeInfo(udf.GetLangVer(), env, typeInfoHelper, nullptr, udf.GetName(), mkqlUserType, udf.GetTypeConfig(), NUdf::IUdfModule::TFlags::TypesOnly, {}, nullptr, logProvider.Get(), &funcInfo); if (!status.IsOk()) { udfRes->SetError(TStringBuilder() << "Failed to find UDF function: " << udf.GetName() diff --git a/yql/essentials/tools/udf_resolver/ya.make b/yql/essentials/tools/udf_resolver/ya.make index 05240ec3b7b..2dff7abf78f 100644 --- a/yql/essentials/tools/udf_resolver/ya.make +++ b/yql/essentials/tools/udf_resolver/ya.make @@ -25,6 +25,7 @@ PEERDIR( yql/essentials/utils/backtrace yql/essentials/utils/sys yql/essentials/sql/pg_dummy + yql/essentials/public/langver ) YQL_LAST_ABI_VERSION() |