diff options
| author | udovichenko-r <udovichenko-r@yandex-team.com> | 2025-02-05 18:17:39 +0300 |
|---|---|---|
| committer | udovichenko-r <udovichenko-r@yandex-team.com> | 2025-02-05 18:59:51 +0300 |
| commit | 2b1d8524874e6ec1acf6d37cd4cf2191d38c3183 (patch) | |
| tree | 96f18cbd698d4076b233a9095d7c0db754800b92 | |
| parent | a80b890c56311693ca846edac72792d702d26f8a (diff) | |
| download | ydb-2b1d8524874e6ec1acf6d37cd4cf2191d38c3183.tar.gz | |
Fix constraints in LogicalOptimizer-PushdownReadColumns
commit_hash:77e1b04d79443b0170fb6bb6d044480235f1bfa6
| -rw-r--r-- | yt/yql/providers/yt/provider/yql_yt_logical_optimize.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/yt/yql/providers/yt/provider/yql_yt_logical_optimize.cpp b/yt/yql/providers/yt/provider/yql_yt_logical_optimize.cpp index 55c3956a7c..caf99f54d5 100644 --- a/yt/yql/providers/yt/provider/yql_yt_logical_optimize.cpp +++ b/yt/yql/providers/yt/provider/yql_yt_logical_optimize.cpp @@ -230,6 +230,7 @@ protected: mapOut.RowSpec->CopySortness(ctx, TYqlRowSpecInfo(map.Output().Item(0).RowSpec())); } mapOut.SetUnique(path.Ref().GetConstraint<TDistinctConstraintNode>(), map.Mapper().Pos(), ctx); + mapOut.RowSpec->SetConstraints(path.Ref().GetConstraintSet()); TExprBase newColumns = Build<TCoVoid>(ctx, path.Pos()).Done(); if (keepColumns) { @@ -271,6 +272,7 @@ protected: mergeOut.RowSpec->CopyTypeOrders(*nativeType); } mergeOut.SetUnique(path.Ref().GetConstraint<TDistinctConstraintNode>(), merge.Pos(), ctx); + mergeOut.RowSpec->SetConstraints(path.Ref().GetConstraintSet()); TSet<TStringBuf> columnSet(effectiveColumns.begin(), effectiveColumns.end()); if (mergeOut.RowSpec->HasAuxColumns()) { |