diff options
| author | ziganshinmr <[email protected]> | 2025-03-27 14:59:42 +0300 |
|---|---|---|
| committer | ziganshinmr <[email protected]> | 2025-03-27 15:16:27 +0300 |
| commit | 3098b5d7f2fe6c0bbee56a7b57371dec369a9e1a (patch) | |
| tree | 81c68ec3e758783d71e03baa8f8ec509e89f8aa1 /yql/essentials/minikql/computation/mkql_block_impl.cpp | |
| parent | e925ea9f73b6f4eda560bf872f261e671c82b2d2 (diff) | |
ListFromBlocks computation node
commit_hash:bae79a39ae78ceed103c460f7949d1a2483e0b73
Diffstat (limited to 'yql/essentials/minikql/computation/mkql_block_impl.cpp')
| -rw-r--r-- | yql/essentials/minikql/computation/mkql_block_impl.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/yql/essentials/minikql/computation/mkql_block_impl.cpp b/yql/essentials/minikql/computation/mkql_block_impl.cpp index ba9238e45a7..e960e8562e3 100644 --- a/yql/essentials/minikql/computation/mkql_block_impl.cpp +++ b/yql/essentials/minikql/computation/mkql_block_impl.cpp @@ -220,7 +220,11 @@ std::vector<arrow::ValueDescr> ToValueDescr(const TVector<TType*>& types) { std::vector<arrow::ValueDescr> res; res.reserve(types.size()); for (const auto& type : types) { - res.emplace_back(ToValueDescr(type)); + if (type) { + res.emplace_back(ToValueDescr(type)); + } else { + res.emplace_back(); + } } return res; |