aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2025-01-30 21:56:38 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2025-01-30 22:10:07 +0300
commitd960f5efa7a37bd73bdec0cda5748ee4f218f376 (patch)
treea19c8d520294dc98c6b4ed2fa3767465e088e54c
parent5141fceffbd2ef7dfa874344160f08c4a952a1a9 (diff)
downloadydb-d960f5efa7a37bd73bdec0cda5748ee4f218f376.tar.gz
Intermediate changes
commit_hash:7649aa792c26c3f770951bc859b8764d24237ef1
-rw-r--r--yql/essentials/core/type_ann/type-ann-coverage.ignore1
-rw-r--r--yql/essentials/tests/s-expressions/minirun/part9/canondata/result.json14
-rw-r--r--yql/essentials/tests/s-expressions/suites/Blocks/ReplicateScalar.yqls14
-rw-r--r--yql/essentials/tests/s-expressions/suites/Blocks/default.cfg0
4 files changed, 29 insertions, 0 deletions
diff --git a/yql/essentials/core/type_ann/type-ann-coverage.ignore b/yql/essentials/core/type_ann/type-ann-coverage.ignore
index 89a4664278..34630abab3 100644
--- a/yql/essentials/core/type_ann/type-ann-coverage.ignore
+++ b/yql/essentials/core/type_ann/type-ann-coverage.ignore
@@ -2,3 +2,4 @@ GraceJoinCoreWrapper
GraceSelfJoinCoreWrapper
SqlExternalFunctionWrapper
UnsafeTimestampCastWrapper
+BlockMapJoinCoreWrapper
diff --git a/yql/essentials/tests/s-expressions/minirun/part9/canondata/result.json b/yql/essentials/tests/s-expressions/minirun/part9/canondata/result.json
index 047a7775e8..352f3fa6c6 100644
--- a/yql/essentials/tests/s-expressions/minirun/part9/canondata/result.json
+++ b/yql/essentials/tests/s-expressions/minirun/part9/canondata/result.json
@@ -27,6 +27,20 @@
"uri": "https://{canondata_backend}/1597364/87512a95e6935beaa948584bb73e2cd84702fc26/resource.tar.gz#test.test_Aggregation-Traits-default.txt-Results_/results.txt"
}
],
+ "test.test[Blocks-ReplicateScalar-default.txt-Debug]": [
+ {
+ "checksum": "b34eb96b84e48b3cd522458999722527",
+ "size": 352,
+ "uri": "https://{canondata_backend}/1784826/0840c5079b4b9426782bf16ffb5b7db6e8a3ded6/resource.tar.gz#test.test_Blocks-ReplicateScalar-default.txt-Debug_/opt.yql"
+ }
+ ],
+ "test.test[Blocks-ReplicateScalar-default.txt-Results]": [
+ {
+ "checksum": "aeeaeb56c73e9780dc30eea45e6a9158",
+ "size": 557,
+ "uri": "https://{canondata_backend}/1784826/0840c5079b4b9426782bf16ffb5b7db6e8a3ded6/resource.tar.gz#test.test_Blocks-ReplicateScalar-default.txt-Results_/results.txt"
+ }
+ ],
"test.test[Builtins-Utf8String-default.txt-Debug]": [
{
"checksum": "46ab51b7ea8e655dd9fa892904c86dab",
diff --git a/yql/essentials/tests/s-expressions/suites/Blocks/ReplicateScalar.yqls b/yql/essentials/tests/s-expressions/suites/Blocks/ReplicateScalar.yqls
new file mode 100644
index 0000000000..522c539a81
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/Blocks/ReplicateScalar.yqls
@@ -0,0 +1,14 @@
+(
+#comment
+(let config (DataSource 'config))
+(let res_sink (DataSink 'result))
+(let value (Int32 '1))
+(let count (Uint64 '10))
+(let r (ReplicateScalar (AsScalar value) (AsScalar count)))
+(let list (AsList '(r (AsScalar count))))
+(let data (Collect (NarrowMap (ToFlow (WideFromBlocks (FromFlow (ExpandMap
+ (ToFlow list) (lambda '(x) (Nth x '0) (Nth x '1)) )))) (lambda '(x) x))))
+(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/Blocks/default.cfg b/yql/essentials/tests/s-expressions/suites/Blocks/default.cfg
new file mode 100644
index 0000000000..e69de29bb2
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/Blocks/default.cfg