Searched refs:file_delta_processors (Results 1 – 1 of 1) sorted by relevance
594 list<FileDeltaProcessor> file_delta_processors; in DeltaReadPartition() local636 file_delta_processors.emplace_back(old_part.path, in DeltaReadPartition()667 file_delta_processors.emplace_back(old_part.path, in DeltaReadPartition()683 << file_delta_processors.size() << " files on partition " in DeltaReadPartition()688 if (file_delta_processors.size() > max_threads) { in DeltaReadPartition()689 file_delta_processors.sort(std::greater<FileDeltaProcessor>()); in DeltaReadPartition()695 for (auto& processor : file_delta_processors) { in DeltaReadPartition()700 for (auto& processor : file_delta_processors) { in DeltaReadPartition()