| 463 | } |
| 464 | |
| 465 | RowVectorPtr |
| 466 | wrapChildren(const RowVectorPtr& input, vector_size_t size, BufferPtr indices) { |
| 467 | std::vector<VectorPtr> wrappedChildren; |
| 468 | wrappedChildren.reserve(input->type()->size()); |
| 469 | for (auto i = 0; i < input->type()->size(); i++) { |
| 470 | wrappedChildren.emplace_back(BaseVector::wrapInDictionary( |
| 471 | BufferPtr(nullptr), indices, size, input->childAt(i))); |
| 472 | } |
| 473 | |
| 474 | return std::make_shared<RowVector>( |
| 475 | input->pool(), input->type(), BufferPtr(nullptr), size, wrappedChildren); |
| 476 | } |
| 477 | } // namespace |
| 478 | |
| 479 | void LocalPartition::notifyPeersToTerminate() { |