Method createUnorderedReader

bolt/exec/Spill.cpp:313–333

}

std::unique_ptr<UnorderedStreamReader<BatchStream>>
SpillPartition::createUnorderedReader(
    memory::MemoryPool* pool,
    bool spillUringEnabled,
    bool isRowBased) {
  BOLT_CHECK_NOT_NULL(pool);
  std::vector<std::unique_ptr<BatchStream>> streams;
  streams.reserve(files_.size());
  for (auto& fileInfo : files_) {
    if (isRowBased) {
      streams.push_back(RowBasedFileSpillBatchStream::create(
          RowBasedSpillReadFile::create(fileInfo, pool, spillUringEnabled)));
    } else {
      streams.push_back(FileSpillBatchStream::create(
          SpillReadFile::create(fileInfo, pool, spillUringEnabled)));
    }
  }
  files_.clear();
  return std::make_unique<UnorderedStreamReader<BatchStream>>(
      std::move(streams));
}

uint32_t FileSpillMergeStream::id() const {
  BOLT_CHECK(!closed_);