Searched refs:file_delta_processors (Results 1 – 1 of 1) sorted by relevance
321 list<FileDeltaProcessor> file_delta_processors; in DeltaReadPartition() local356 file_delta_processors.emplace_back(old_part.path, in DeltaReadPartition()385 file_delta_processors.emplace_back( in DeltaReadPartition()402 if (file_delta_processors.size() > max_threads) { in DeltaReadPartition()403 file_delta_processors.sort(std::greater<FileDeltaProcessor>()); in DeltaReadPartition()409 for (auto& processor : file_delta_processors) { in DeltaReadPartition()414 for (auto& processor : file_delta_processors) { in DeltaReadPartition()