Searched refs:file_delta_processors (Results 1 – 1 of 1) sorted by relevance
419 list<FileDeltaProcessor> file_delta_processors; in DeltaReadPartition() local458 file_delta_processors.emplace_back(old_part.path, in DeltaReadPartition()487 file_delta_processors.emplace_back( in DeltaReadPartition()504 if (file_delta_processors.size() > max_threads) { in DeltaReadPartition()505 file_delta_processors.sort(std::greater<FileDeltaProcessor>()); in DeltaReadPartition()511 for (auto& processor : file_delta_processors) { in DeltaReadPartition()516 for (auto& processor : file_delta_processors) { in DeltaReadPartition()