diff options
author | imunkin <imunkin@yandex-team.com> | 2025-01-17 16:12:38 +0300 |
---|---|---|
committer | imunkin <imunkin@yandex-team.com> | 2025-01-17 16:29:14 +0300 |
commit | 5bf3fd8cf1463c43723f1c8ba9d2322073f93c04 (patch) | |
tree | 89f3800c888c589798de9e4f5a34384eda2f6808 /yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp | |
parent | e2b9ea56b89acb80b934fcfa26a782bb92e1d39e (diff) | |
download | ydb-5bf3fd8cf1463c43723f1c8ba9d2322073f93c04.tar.gz |
YQL-19424: Use WideStream instead of WideFlow in WideFromBlocks computation node
commit_hash:21c84a9004cc57883d949b8fc637fc3ae7bfbda9
Diffstat (limited to 'yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp')
-rw-r--r-- | yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp b/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp index 67cf2acc49..fe65e76d1e 100644 --- a/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp +++ b/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp @@ -66,7 +66,7 @@ void DoBlockExistsOffset(size_t length, size_t offset) { items[4], }; }); - node = pb.WideFromBlocks(node); + node = pb.ToFlow(pb.WideFromBlocks(pb.FromFlow(node))); node = pb.NarrowMap(node, [&](TRuntimeNode::TList items) -> TRuntimeNode { return pb.NewTuple(outputTupleType, {items[0], items[1], items[2], items[3]}); }); |