aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVitaly Stoyan <vitstn@gmail.com>2022-06-29 22:47:38 +0300
committerVitaly Stoyan <vitstn@gmail.com>2022-06-29 22:47:38 +0300
commitcce3e253f5356f010631e1fb64d4e91414ad94db (patch)
tree1409f8451ad0e359a233657ff954e4c5bd263daf
parentdb6e58f55cf68d279e79172f0ec3a7e2e0a81609 (diff)
downloadydb-cce3e253f5356f010631e1fb64d4e91414ad94db.tar.gz
YQL-14728 a barrier to skip evaluation of inner scalar select many times
ref:a261c3e3417f62214561d70bd1b8165adb200ce8
-rw-r--r--ydb/library/yql/core/common_opt/yql_co_pgselect.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/ydb/library/yql/core/common_opt/yql_co_pgselect.cpp b/ydb/library/yql/core/common_opt/yql_co_pgselect.cpp
index daf628ce66..4595d7cf7c 100644
--- a/ydb/library/yql/core/common_opt/yql_co_pgselect.cpp
+++ b/ydb/library/yql/core/common_opt/yql_co_pgselect.cpp
@@ -299,7 +299,9 @@ std::pair<TExprNode::TPtr, TExprNode::TPtr> RewriteSubLinks(TPositionHandle pos,
auto filtered = ctx.Builder(node->Pos())
.Callable("Filter")
- .Add(0, select)
+ .Callable(0, "Collect")
+ .Add(0, select)
+ .Seal()
.Add(1, filterLambda)
.Seal()
.Build();