aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVitaly Stoyan <vvvv@ydb.tech>2024-01-26 12:54:52 +0300
committerGitHub <noreply@github.com>2024-01-26 12:54:52 +0300
commit98129732741a9b10f97c86f439da5a11220ed216 (patch)
tree9e0a627abe2d1b23916ca73a126b22ed74643193
parenta3589168e475fccc7327d61ed9061ece6b5ec8b8 (diff)
downloadydb-98129732741a9b10f97c86f439da5a11220ed216.tar.gz
Support of Merge along with Extend (#1307)
-rw-r--r--ydb/library/yql/core/services/yql_lineage.cpp2
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);