aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp
diff options
context:
space:
mode:
authorimunkin <imunkin@yandex-team.com>2025-01-17 16:12:38 +0300
committerimunkin <imunkin@yandex-team.com>2025-01-17 16:29:14 +0300
commit5bf3fd8cf1463c43723f1c8ba9d2322073f93c04 (patch)
tree89f3800c888c589798de9e4f5a34384eda2f6808 /yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp
parente2b9ea56b89acb80b934fcfa26a782bb92e1d39e (diff)
downloadydb-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.cpp12
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");