Merge pull request #11788 from ydb-platform/mergelibs-241120-1113

Library import 241120-1113

1 files changed, 47 insertions, 0 deletions

diff --git a/yql/essentials/tests/sql/suites/optimizers/test_lmap_opts.sql b/yql/essentials/tests/sql/suites/optimizers/test_lmap_opts.sql
new file mode 100644
index 0000000000..90c0f8a2a7
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/optimizers/test_lmap_opts.sql
@@ -0,0 +1,47 @@
+/* syntax version 1 */
+-- not supported on windows
+/* postgres can not */
+$udfScript = @@
+
+import collections;
+
+def processRows(prefix, rowList, separator):
+    ResultRow = collections.namedtuple("ResultRow", ["Result"]);
+
+    result = [];
+    for row in rowList:
+        resultValue = prefix + row.Name + separator + row.Value;
+        resultItem = ResultRow(Result=resultValue);
+        result.append(resultItem);
+    
+    return result;
+@@;
+
+$udf = Python::processRows(
+    Callable<(String, List<Struct<Name:String, Value:String>>, String)->List<Struct<Result:String>>>,
+    $udfScript
+);
+
+$data = (
+    SELECT key AS Name, value AS Value FROM plato.Input0
+);
+
+$prefix = ">>";
+
+$p1 = (
+    PROCESS $data USING $udf($prefix, TableRows(), "=") WHERE Name != "foo"
+);
+
+$p2 = (
+    SELECT Result AS Data FROM $p1
+);
+
+$p3 = (
+    PROCESS $p2 USING Streaming::Process(TableRows(), "grep", AsList("180"))
+);
+
+$p4 = (
+    SELECT Data AS FinalResult FROM $p3
+);
+
+SELECT Avg(Length(FinalResult)) AS AvgResultLength FROM $p4;