diff options
Diffstat (limited to 'yql/essentials/core/yql_sql_combine_expander.cpp')
| -rw-r--r-- | yql/essentials/core/yql_sql_combine_expander.cpp | 18 |
1 files changed, 7 insertions, 11 deletions
diff --git a/yql/essentials/core/yql_sql_combine_expander.cpp b/yql/essentials/core/yql_sql_combine_expander.cpp index 62691e26701..9d52cfad700 100644 --- a/yql/essentials/core/yql_sql_combine_expander.cpp +++ b/yql/essentials/core/yql_sql_combine_expander.cpp @@ -330,22 +330,18 @@ TExprNode::TPtr ExpandSqlCombine(const TExprNode::TPtr& node, TExprContext& ctx, .Seal().Build(); const auto result = ctx.Builder(pos) - .Callable("PartitionsByKeys") + .Callable("LPartitionsByKeys") .Add(0, std::move(merged)) .Add(1, partitionKeySelector) .Add(2, std::move(presortDirection)) .Add(3, std::move(presortKeySelector)) .Lambda(4) - .Param("partitionList") - .Callable("ForwardList") - .Callable(0, "Chopper") - .Callable(0, "ToStream") - .Arg(0, "partitionList") - .Seal() - .Add(1, partitionKeySelector) - .Add(2, std::move(groupSwitch)) - .Add(3, std::move(chopperHandler)) - .Seal() + .Param("partitionStream") + .Callable("Chopper") + .Arg(0, "partitionStream") + .Add(1, partitionKeySelector) + .Add(2, std::move(groupSwitch)) + .Add(3, std::move(chopperHandler)) .Seal() .Seal() .Seal().Build(); |