diff options
author | Vitaly Stoyan <vvvv@ydb.tech> | 2024-01-26 12:54:52 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-01-26 12:54:52 +0300 |
commit | 98129732741a9b10f97c86f439da5a11220ed216 (patch) | |
tree | 9e0a627abe2d1b23916ca73a126b22ed74643193 | |
parent | a3589168e475fccc7327d61ed9061ece6b5ec8b8 (diff) | |
download | ydb-98129732741a9b10f97c86f439da5a11220ed216.tar.gz |
Support of Merge along with Extend (#1307)
-rw-r--r-- | ydb/library/yql/core/services/yql_lineage.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/core/services/yql_lineage.cpp b/ydb/library/yql/core/services/yql_lineage.cpp index 5f251c0389..9b7d9b05be 100644 --- a/ydb/library/yql/core/services/yql_lineage.cpp +++ b/ydb/library/yql/core/services/yql_lineage.cpp @@ -218,7 +218,7 @@ private: HandleFlatMap(lineage, node); } else if (node.IsCallable("Aggregate")) { HandleAggregate(lineage, node); - } else if (node.IsCallable("Extend")) { + } else if (node.IsCallable({"Extend","OrderedExtend","Merge"})) { HandleExtend(lineage, node); } else if (node.IsCallable({"CalcOverWindow","CalcOverSessionWindow","CalcOverWindowGroup"})) { HandleWindow(lineage, node); |