thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-24 08:32:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Simpler way to resize pipeline

Browse Source
This commit is contained in:
Igor Nikonov 2023-04-09 21:26:39 +00:00
parent 6fe6e1fea5
commit 1187534545
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Storages/StorageFile.cpp
View File

@ -797,7 +797,7 @@ Pipe StorageFile::read(
/// It happens if globs in file(path, ...) expands to empty set i.e. no files to process /// It happens if globs in file(path, ...) expands to empty set i.e. no files to process
if (num_streams > 0 && num_streams < max_num_streams) if (num_streams > 0 && num_streams < max_num_streams)
{ {
pipe.addTransform(std::make_shared<ResizeProcessor>(pipe.getHeader(), num_streams, max_num_streams)); pipe.resize(max_num_streams);
} }
return pipe; return pipe;
} }