diff options
author | robot-piglet <[email protected]> | 2025-05-28 17:20:42 +0300 |
---|---|---|
committer | robot-piglet <[email protected]> | 2025-05-28 17:33:37 +0300 |
commit | 527ad7a63e71ce09e5b6e02cd17f863cb2c830e0 (patch) | |
tree | 90966679d587a3805f26cf330ef3273c3025e88d /yql/essentials/sql/v1/complete/sql_complete_ut.cpp | |
parent | afbcef3f55df5bc1054cd00a11f39cab08f83095 (diff) |
Intermediate changes
commit_hash:ab24b3db82789b77ad465efa64de93c5eab43629
Diffstat (limited to 'yql/essentials/sql/v1/complete/sql_complete_ut.cpp')
-rw-r--r-- | yql/essentials/sql/v1/complete/sql_complete_ut.cpp | 28 |
1 files changed, 9 insertions, 19 deletions
diff --git a/yql/essentials/sql/v1/complete/sql_complete_ut.cpp b/yql/essentials/sql/v1/complete/sql_complete_ut.cpp index f3430fca4a0..7460924b48f 100644 --- a/yql/essentials/sql/v1/complete/sql_complete_ut.cpp +++ b/yql/essentials/sql/v1/complete/sql_complete_ut.cpp @@ -2,7 +2,6 @@ #include <yql/essentials/sql/v1/complete/syntax/grammar.h> #include <yql/essentials/sql/v1/complete/name/cluster/static/discovery.h> -#include <yql/essentials/sql/v1/complete/name/object/dispatch/schema.h> #include <yql/essentials/sql/v1/complete/name/object/simple/schema.h> #include <yql/essentials/sql/v1/complete/name/object/simple/static/schema.h> #include <yql/essentials/sql/v1/complete/name/service/ranking/frequency.h> @@ -17,6 +16,8 @@ #include <yql/essentials/sql/v1/lexer/antlr4_pure_ansi/lexer.h> #include <library/cpp/testing/unittest/registar.h> +#include <library/cpp/iterator/iterate_keys.h> +#include <library/cpp/iterator/functools.h> #include <util/charset/utf8.h> @@ -79,7 +80,7 @@ Y_UNIT_TEST_SUITE(SqlCompleteTests) { }, }; - THashMap<TString, THashMap<TString, TVector<TFolderEntry>>> fss = { + THashMap<TString, THashMap<TString, TVector<TFolderEntry>>> fs = { {"", {{"/", {{"Folder", "local"}, {"Folder", "test"}, {"Folder", "prod"}, @@ -99,30 +100,19 @@ Y_UNIT_TEST_SUITE(SqlCompleteTests) { {{"/", {{"Table", "maxim"}}}}}, }; - TVector<TString> clusters; - for (const auto& [cluster, _] : fss) { - clusters.emplace_back(cluster); - } - EraseIf(clusters, [](const auto& s) { return s.empty(); }); + auto clustersIt = NFuncTools::Filter( + [](const auto& x) { return !x.empty(); }, IterateKeys(fs)); + TVector<TString> clusters(begin(clustersIt), end(clustersIt)); TFrequencyData frequency; - IRanking::TPtr ranking = MakeDefaultRanking(frequency); - - THashMap<TString, ISchema::TPtr> schemasByCluster; - for (auto& [cluster, fs] : fss) { - schemasByCluster[std::move(cluster)] = - MakeSimpleSchema( - MakeStaticSimpleSchema(std::move(fs))); - } - TVector<INameService::TPtr> children = { MakeStaticNameService(std::move(names), frequency), - MakeSchemaNameService(MakeDispatchSchema(std::move(schemasByCluster))), + MakeSchemaNameService(MakeSimpleSchema(MakeStaticSimpleSchema(std::move(fs)))), MakeClusterNameService(MakeStaticClusterDiscovery(std::move(clusters))), }; - - INameService::TPtr service = MakeUnionNameService(std::move(children), ranking); + INameService::TPtr service = MakeUnionNameService( + std::move(children), MakeDefaultRanking(frequency)); return MakeSqlCompletionEngine(std::move(lexer), std::move(service)); } |