diff options
author | uzhas <uzhas@ydb.tech> | 2022-09-09 15:22:32 +0300 |
---|---|---|
committer | uzhas <uzhas@ydb.tech> | 2022-09-09 15:22:32 +0300 |
commit | 42578558983241f5b879a6453387a47c4ada2d27 (patch) | |
tree | 40e68a0282698819660515babe1cff1260563275 | |
parent | 7dbd7a386cada4de30e2313e53e164aa48121340 (diff) | |
download | ydb-42578558983241f5b879a6453387a47c4ada2d27.tar.gz |
,s3: fix extract members
-rw-r--r-- | ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp b/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp index e41a804261..015254f159 100644 --- a/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp +++ b/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp @@ -441,7 +441,8 @@ public: } newPaths = ctx.ChangeChildren(maybeS3SourceSettings.Cast().Paths().Ref(), std::move(newPathItems)); - TExprNode::TPtr newExtra = ctx.ChangeChildren(*originalExtra, std::move(newExtraColumnsExtents)); + + TExprNode::TPtr newExtra = ctx.NewCallable(extraColumnsSetting->Pos(), "OrderedExtend", std::move(newExtraColumnsExtents)); newSettings = TExprBase(extraTypeItems.empty() ? RemoveSetting(settings.Cast().Ref(), "extraColumns", ctx) : ReplaceSetting(settings.Cast().Ref(), extraColumnsSetting->Pos(), "extraColumns", newExtra, ctx)); } |