Lineage: support of TopSort (#3858)

Author: vitstn

ydb/library/yql/core/services/yql_lineage.cpp

@@ -249,6 +249,7 @@ class TLineageScanner {
             "Skip", 
             "Take", 
             "Sort", 
+            "TopSort", 
             "AssumeSorted", 
             "SkipNullMembers"})) {
             lineage = *CollectLineage(node.Head());

ydb/library/yql/tests/sql/sql2yql/canondata/result.json

@@ -10023,6 +10023,13 @@
             "uri": "https://{canondata_backend}/1937027/973c239492ba32946806ddc66cf0af4b38c06ae8/resource.tar.gz#test_sql2yql.test_lineage-some_tablerow_/sql.yql"
         }
     ],
+    "test_sql2yql.test[lineage-topsort]": [
+        {
+            "checksum": "bde990c0abcf6b66865ae96c8cd0a99f",
+            "size": 2031,
+            "uri": "https://{canondata_backend}/1937429/d9e26546ec60615ac3a6bdb8250a95b71cccc205/resource.tar.gz#test_sql2yql.test_lineage-topsort_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[lineage-union_all_tablerow]": [
         {
             "checksum": "5cb779df9c36033dfd0ae226d4e77b88",
@@ -28356,6 +28363,13 @@
             "uri": "https://{canondata_backend}/1880306/64654158d6bfb1289c66c626a8162239289559d0/resource.tar.gz#test_sql_format.test_lineage-some_tablerow_/formatted.sql"
         }
     ],
+    "test_sql_format.test[lineage-topsort]": [
+        {
+            "checksum": "513459567bea13ff52bf88a00e2d800b",
+            "size": 188,
+            "uri": "https://{canondata_backend}/1937429/d9e26546ec60615ac3a6bdb8250a95b71cccc205/resource.tar.gz#test_sql_format.test_lineage-topsort_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[lineage-union_all_tablerow]": [
         {
             "checksum": "d84f10845f891333d67cfa1092a53d67",

ydb/library/yql/tests/sql/suites/lineage/topsort.sql

@@ -0,0 +1,8 @@
+USE plato;
+
+INSERT INTO Output
+SELECT a.value
+FROM Input AS a
+INNER JOIN (SELECT value FROM Input ORDER BY value LIMIT 1) AS b
+USING (value);
+

ydb/library/yql/tests/sql/yt_native_file/part7/canondata/result.json

@@ -1418,6 +1418,39 @@
             "uri": "https://{canondata_backend}/1899731/fba000ee13d15ca06c769e91a11df3e541feafd4/resource.tar.gz#test.test_lineage-select_all-default.txt-Results_/Output.yqlrun.txt.attr"
         }
     ],
+    "test.test[lineage-topsort-default.txt-Debug]": [
+        {
+            "checksum": "33db9ae4e5175d8a7cd21f6a4a5338d4",
+            "size": 3610,
+            "uri": "https://{canondata_backend}/1942173/16a6cdf0aea72ee3153163f98e7fe95d7adc75d1/resource.tar.gz#test.test_lineage-topsort-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[lineage-topsort-default.txt-Lineage]": [
+        {
+            "checksum": "32315a7b9568b4c2293678c2a6313e69",
+            "size": 936,
+            "uri": "https://{canondata_backend}/1942173/16a6cdf0aea72ee3153163f98e7fe95d7adc75d1/resource.tar.gz#test.test_lineage-topsort-default.txt-Lineage_/results.txt"
+        }
+    ],
+    "test.test[lineage-topsort-default.txt-Plan]": [
+        {
+            "checksum": "e9133b4d90450db3c79fcddf324513bb",
+            "size": 6798,
+            "uri": "https://{canondata_backend}/1942173/16a6cdf0aea72ee3153163f98e7fe95d7adc75d1/resource.tar.gz#test.test_lineage-topsort-default.txt-Plan_/plan.txt"
+        }
+    ],
+    "test.test[lineage-topsort-default.txt-Results]": [
+        {
+            "checksum": "2be0db951e2ae908c8e71f2951e76bf2",
+            "size": 27,
+            "uri": "https://{canondata_backend}/1942173/16a6cdf0aea72ee3153163f98e7fe95d7adc75d1/resource.tar.gz#test.test_lineage-topsort-default.txt-Results_/Output.txt"
+        },
+        {
+            "checksum": "7a5f062202f47876caa00b67be297bb0",
+            "size": 377,
+            "uri": "https://{canondata_backend}/1942173/16a6cdf0aea72ee3153163f98e7fe95d7adc75d1/resource.tar.gz#test.test_lineage-topsort-default.txt-Results_/Output.yqlrun.txt.attr"
+        }
+    ],
     "test.test[match_recognize-simple_paritioning-default.txt-Debug]": [
         {
             "checksum": "20ea23851178e349eb7bc5c1e5de063b",