diff options
| author | aneporada <aneporada@yandex-team.ru> | 2022-04-26 20:34:43 +0300 |
|---|---|---|
| committer | aneporada <aneporada@yandex-team.ru> | 2022-04-26 20:34:43 +0300 |
| commit | adc1bef0e6c8d177a6e2fecb7c822696582b29df (patch) | |
| tree | 59fb0d2fd1e50cf8160361d5f80751a8769026bf | |
| parent | 90e7fdef8c07be660fe11c3dab03766b144d2649 (diff) | |
| download | ydb-adc1bef0e6c8d177a6e2fecb7c822696582b29df.tar.gz | |
[YQL-14742] Remove unneeded (and broken) StablePickle() when grouing by SessionWindow.
ref:98c7941152d4291a88782db91c3b7037f0822391
| -rw-r--r-- | ydb/library/yql/core/yql_opt_aggregate.cpp | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/ydb/library/yql/core/yql_opt_aggregate.cpp b/ydb/library/yql/core/yql_opt_aggregate.cpp index 662402e6315..e977a47feae 100644 --- a/ydb/library/yql/core/yql_opt_aggregate.cpp +++ b/ydb/library/yql/core/yql_opt_aggregate.cpp @@ -1452,32 +1452,6 @@ TExprNode::TPtr ExpandAggregate(bool allowPickle, const TExprNode::TPtr& node, T preprocessLambda = AddSessionParamsMemberLambda(node->Pos(), sessionStartMemberName, "", keyExtractor, sessionKey, sessionInit, sessionUpdate, ctx); - if (!IsDataOrOptionalOfData(sessionKeyType)) { - preprocessLambda = ctx.Builder(node->Pos()) - .Lambda() - .Param("stream") - .Callable("OrderedMap") - .Apply(0, preprocessLambda) - .With(0, "stream") - .Seal() - .Lambda(1) - .Param("item") - .Callable("ReplaceMember") - .Arg(0, "item") - .Atom(1, sessionStartMemberName) - .Callable(2, "StablePickle") - .Callable(0, "Member") - .Arg(0, "item") - .Atom(1, sessionStartMemberName) - .Seal() - .Seal() - .Seal() - .Seal() - .Seal() - .Seal() - .Build(); - } - condenseSwitch = ctx.Builder(node->Pos()) .Lambda() .Param("item") |