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/mkql_block_agg.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/mkql_block_agg.cpp')
-rw-r--r-- | yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp b/yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp index fef2712c4f..266e909b98 100644 --- a/yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp +++ b/yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp @@ -442,18 +442,6 @@ size_t GetBitmapPopCount(const std::shared_ptr<arrow::ArrayData>& arr) { return GetSparseBitmapPopCount(src, len); } -TArrayRef<TType *const> GetWideComponents(TType* type) { - if (type->IsFlow()) { - const auto outputFlowType = AS_TYPE(TFlowType, type); - return GetWideComponents(outputFlowType); - } - if (type->IsStream()) { - const auto outputStreamType = AS_TYPE(TStreamType, type); - return GetWideComponents(outputStreamType); - } - MKQL_ENSURE(false, "Expect either flow or stream"); -} - size_t CalcMaxBlockLenForOutput(TType* out) { const auto wideComponents = GetWideComponents(out); MKQL_ENSURE(wideComponents.size() > 0, "Expecting at least one output column"); |