diff options
author | udovichenko-r <udovichenko-r@yandex-team.com> | 2025-02-10 20:03:39 +0300 |
---|---|---|
committer | udovichenko-r <udovichenko-r@yandex-team.com> | 2025-02-10 22:09:07 +0300 |
commit | 7743bf2e4f41f9d4220fbab577bb1257f19d57d3 (patch) | |
tree | ef65171ec0f6c2875474fc2f7da71a9212dbb05e | |
parent | 00686935834f8dddef76e9d12d0ff6a17455b5cf (diff) | |
download | ydb-7743bf2e4f41f9d4220fbab577bb1257f19d57d3.tar.gz |
Fix PhysicalOptimizer-MultiReduceFieldsSubset
commit_hash:1e34b093f0bfce863588a645b6324aa5a8d966cd
-rw-r--r-- | yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp b/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp index a2f5fd4100..5f5ed8238c 100644 --- a/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp +++ b/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp @@ -99,14 +99,14 @@ TMaybeNode<TExprBase> TYtPhysicalOptProposalTransformer::LambdaVisitFieldsSubset auto itemType = visitLambda->Head().Head().GetTypeAnn()->Cast<TStructExprType>(); auto reduceBy = NYql::GetSettingAsColumnList(op.Settings().Ref(), EYtSettingType::ReduceBy); for (auto& col: reduceBy) { - if (auto type = itemType->FindItemType(col)) { - memberSet.insert(type->Cast<TItemExprType>()->GetName()); + if (itemType->FindItem(col)) { + memberSet.insert(col); } } auto sortBy = NYql::GetSettingAsColumnList(op.Settings().Ref(), EYtSettingType::SortBy); for (auto& col: sortBy) { - if (auto type = itemType->FindItemType(col)) { - memberSet.insert(type->Cast<TItemExprType>()->GetName()); + if (itemType->FindItem(col)) { + memberSet.insert(col); } } |