aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <udovichenko-r@yandex-team.com>2024-12-27 19:11:50 +0300
committerudovichenko-r <udovichenko-r@yandex-team.com>2024-12-27 19:30:46 +0300
commite81ae26da5e403c8f2d5cb84dc6ca0e38fffc6bf (patch)
tree61a5643504330348c0a43572efe05c6221b1c1da
parent012adaae42273729f5ddf9cf464b72403f9d4500 (diff)
downloadydb-e81ae26da5e403c8f2d5cb84dc6ca0e38fffc6bf.tar.gz
[yt provider] Simplify constraints in YtPath node
YQL-19455 commit_hash:47b08bb260531620876614cda4e65e3e7149f8f0
-rw-r--r--yt/yql/providers/yt/provider/yql_yt_datasource_constraints.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/yql/providers/yt/provider/yql_yt_datasource_constraints.cpp b/yt/yql/providers/yt/provider/yql_yt_datasource_constraints.cpp
index 3c5d2f4554..8eada7e706 100644
--- a/yt/yql/providers/yt/provider/yql_yt_datasource_constraints.cpp
+++ b/yt/yql/providers/yt/provider/yql_yt_datasource_constraints.cpp
@@ -99,19 +99,19 @@ public:
if (const auto sort = path.Table().Ref().GetConstraint<TSortedConstraintNode>()) {
if (const auto filtered = sort->FilterFields(ctx, filter)) {
- path.Ptr()->AddConstraint(filtered);
+ path.Ptr()->AddConstraint(filtered->GetSimplifiedForType(*path.Ref().GetTypeAnn(), ctx));
}
}
if (const auto uniq = path.Table().Ref().GetConstraint<TUniqueConstraintNode>()) {
if (const auto filtered = uniq->FilterFields(ctx, filter)) {
- path.Ptr()->AddConstraint(filtered);
+ path.Ptr()->AddConstraint(filtered->GetSimplifiedForType(*path.Ref().GetTypeAnn(), ctx));
}
}
if (const auto dist = path.Table().Ref().GetConstraint<TDistinctConstraintNode>()) {
if (const auto filtered = dist->FilterFields(ctx, filter)) {
- path.Ptr()->AddConstraint(filtered);
+ path.Ptr()->AddConstraint(filtered->GetSimplifiedForType(*path.Ref().GetTypeAnn(), ctx));
}
}