| 35 | } |
| 36 | |
| 37 | std::unique_ptr<ValueVector> RJOutputWriter::createVector(const LogicalType& type) { |
| 38 | auto vector = std::make_unique<ValueVector>(type.copy(), storage::MemoryManager::Get(*context)); |
| 39 | vector->state = DataChunkState::getSingleValueDataChunkState(); |
| 40 | vectors.push_back(vector.get()); |
| 41 | return vector; |
| 42 | } |
| 43 | |
| 44 | PathsOutputWriter::PathsOutputWriter(main::ClientContext* context, |
| 45 | NodeOffsetMaskMap* outputNodeMask, nodeID_t sourceNodeID, PathsOutputWriterInfo info, |