diff options
| author | robot-piglet <robot-piglet@yandex-team.com> | 2025-01-30 21:56:38 +0300 |
|---|---|---|
| committer | robot-piglet <robot-piglet@yandex-team.com> | 2025-01-30 22:10:07 +0300 |
| commit | d960f5efa7a37bd73bdec0cda5748ee4f218f376 (patch) | |
| tree | a19c8d520294dc98c6b4ed2fa3767465e088e54c | |
| parent | 5141fceffbd2ef7dfa874344160f08c4a952a1a9 (diff) | |
| download | ydb-d960f5efa7a37bd73bdec0cda5748ee4f218f376.tar.gz | |
Intermediate changes
commit_hash:7649aa792c26c3f770951bc859b8764d24237ef1
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 |