aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/tests/s-expressions/suites/YtNative
diff options
context:
space:
mode:
authorudovichenko-r <udovichenko-r@yandex-team.com>2024-11-18 18:00:20 +0300
committerudovichenko-r <udovichenko-r@yandex-team.com>2024-11-18 18:32:34 +0300
commit227883e6978c3b90e91b931488e9dd4c56c350bf (patch)
tree925008663989d95a31a74a4f6e19886ecb47bd47 /yql/essentials/tests/s-expressions/suites/YtNative
parent0dc8d9e60034615bb2e67687bfd94a4ea3e7296f (diff)
downloadydb-227883e6978c3b90e91b931488e9dd4c56c350bf.tar.gz
YQL-19206 Move contrib/ydb/library/yql/tests/s-expressions/suites -> yql/essentials/tests/s-expressions/suites
commit_hash:02beb73b0c072658a9f2dc8bd9762791936b4e29
Diffstat (limited to 'yql/essentials/tests/s-expressions/suites/YtNative')
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.cfg3
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.yql12
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureList.yql10
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureLongList.yql15
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureNonList.yql10
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureStructList.yql13
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureStructListWithFields.yql13
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.cfg3
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.yql10
-rw-r--r--yql/essentials/tests/s-expressions/suites/YtNative/default.cfg1
10 files changed, 90 insertions, 0 deletions
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.cfg b/yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.cfg
new file mode 100644
index 0000000000..907c9ea175
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.cfg
@@ -0,0 +1,3 @@
+res result.txt
+file myfile yql/essentials/udfs/test/test_import/libtest_import_udf.so
+os linux
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.yql
new file mode 100644
index 0000000000..92abfcd35c
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureImportUdf.yql
@@ -0,0 +1,12 @@
+# not supported on windows
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'ImportUdfs 'myfile))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (Apply (Udf 'TestImportUdf.Concat) (String 'abc) (String '"")))
+(let world (Write! world res_sink (Key) data '('('type))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureList.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureList.yql
new file mode 100644
index 0000000000..224d23514f
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureList.yql
@@ -0,0 +1,10 @@
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (AsList (Uint32 '1)))
+(let world (Write! world res_sink (Key) data '('('type))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureLongList.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureLongList.yql
new file mode 100644
index 0000000000..94a8922948
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureLongList.yql
@@ -0,0 +1,15 @@
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (AsList (Uint32 '1)))
+(let data (Extend data data data data data))
+(let data (Extend data data data data data))
+(let data (Extend data data data data data))
+(let data (Extend data data data data data))
+(let data (Extend data data))
+(let world (Write! world res_sink (Key) data '('('type))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureNonList.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureNonList.yql
new file mode 100644
index 0000000000..eb00aa902e
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureNonList.yql
@@ -0,0 +1,10 @@
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (Uint32 '1))
+(let world (Write! world res_sink (Key) data '('('type))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureStructList.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureStructList.yql
new file mode 100644
index 0000000000..0c6513f8c7
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureStructList.yql
@@ -0,0 +1,13 @@
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (AsList
+ (AsStruct '('b (Uint32 '1)) '('a (String 'a)) '('c (String 'DDD)))
+ (AsStruct '('b (Uint32 '2)) '('a (String 'b)) '('c (String 'EEE)))
+))
+(let world (Write! world res_sink (Key) data '('('type))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureStructListWithFields.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureStructListWithFields.yql
new file mode 100644
index 0000000000..623ed4b8b0
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureStructListWithFields.yql
@@ -0,0 +1,13 @@
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (AsList
+ (AsStruct '('b (Uint32 '1)) '('a (String 'a)) '('c (String 'DDD)))
+ (AsStruct '('b (Uint32 '2)) '('a (String 'b)) '('c (String 'EEE)))
+))
+(let world (Write! world res_sink (Key) data '('('type) '('columns '('c 'a 'b)))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.cfg b/yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.cfg
new file mode 100644
index 0000000000..8da645df35
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.cfg
@@ -0,0 +1,3 @@
+res result.txt
+udf simple_udf
+
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.yql b/yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.yql
new file mode 100644
index 0000000000..0f09553c83
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/PureUdf.yql
@@ -0,0 +1,10 @@
+(
+#comment
+(let config (DataSource 'config))
+(let world (Configure! world config 'PureDataSource 'yt))
+(let res_sink (DataSink 'result))
+(let data (Apply (Udf 'SimpleUdf.Echo) (String 'abc)))
+(let world (Write! world res_sink (Key) data '('('type))))
+(let world (Commit! world res_sink))
+(return world)
+)
diff --git a/yql/essentials/tests/s-expressions/suites/YtNative/default.cfg b/yql/essentials/tests/s-expressions/suites/YtNative/default.cfg
new file mode 100644
index 0000000000..00dec6c3f8
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/YtNative/default.cfg
@@ -0,0 +1 @@
+res result.txt