| 338 | } |
| 339 | |
| 340 | std::unique_ptr<SpillMergeStream> ConcatFilesSpillMergeStream::create( |
| 341 | uint32_t id, |
| 342 | std::vector<std::unique_ptr<SpillReadFile>> spillFiles) { |
| 343 | auto spillStream = std::unique_ptr<ConcatFilesSpillMergeStream>( |
| 344 | new ConcatFilesSpillMergeStream(id, std::move(spillFiles))); |
| 345 | spillStream->nextBatch(); |
| 346 | return spillStream; |
| 347 | } |
| 348 | |
| 349 | uint32_t ConcatFilesSpillMergeStream::id() const { |
| 350 | return id_; |