diff options
| author | a-romanov <Anton.Romanov@ydb.tech> | 2023-04-20 19:56:07 +0300 |
|---|---|---|
| committer | a-romanov <Anton.Romanov@ydb.tech> | 2023-04-20 19:56:07 +0300 |
| commit | f576b57e89f1fc8d34332aa19629231e715743c8 (patch) | |
| tree | 734dd4e7a144b1b5a5289a69c5e5726ed746fac6 | |
| parent | 2443476d1388a3c3054dbd8adb4a8b04a8494abe (diff) | |
| download | ydb-f576b57e89f1fc8d34332aa19629231e715743c8.tar.gz | |
YQL-15415 Swap Unordered & MapJoinCore.
| -rw-r--r-- | ydb/library/yql/core/common_opt/yql_co_flow2.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/core/common_opt/yql_co_flow2.cpp b/ydb/library/yql/core/common_opt/yql_co_flow2.cpp index 9919845b3a2..497c1ced07d 100644 --- a/ydb/library/yql/core/common_opt/yql_co_flow2.cpp +++ b/ydb/library/yql/core/common_opt/yql_co_flow2.cpp @@ -2183,7 +2183,8 @@ void RegisterCoFlowCallables2(TCallableOptimizerMap& map) { if (node->Head().IsCallable({ "Collect", "LazyList", "ForwardList","Iterator","FromFlow","ToFlow","AssumeUnique","AssumeDistinct", "FilterNullMembers","SkipNullMembers","FilterNullElements","SkipNullElements", - "ExpandMap","WideMap","WideFilter","NarrowMap","NarrowFlatMap","NarrowMultiMap" + "ExpandMap","WideMap","WideFilter","NarrowMap","NarrowFlatMap","NarrowMultiMap", + "MapJoinCore" })) { YQL_CLOG(DEBUG, Core) << "Swap " << node->Content() << " with " << node->Head().Content(); return ctx.SwapWithHead(*node); |