aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/minikql/comp_nodes/mkql_block_agg.cpp
diff options
context:
space:
mode:
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");