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

Merge pull request #54533 from ClickHouse/parallelize_insert_from_infile_by_file

Browse Source 
parallelize infile
This commit is contained in:
alesapin 2023-09-15 14:30:49 +02:00 committed by GitHub
commit fd2ac0cb8f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/QueryPipeline/QueryPipeline.cpp
View File

@ -353,6 +353,7 @@ QueryPipeline::QueryPipeline(Pipe pipe)
totals = pipe.getTotalsPort();
extremes = pipe.getExtremesPort();
partial_result = pipe.getPartialResultPort(0);
num_threads = pipe.max_parallel_streams;
processors = std::move(pipe.processors);
checkPulling(*processors, output, totals, extremes, partial_result);