From ed7b687a696b53d7443432122e954b88bc30883b Mon Sep 17 00:00:00 2001 From: Max Kainov Date: Tue, 12 Sep 2023 08:58:43 +0000 Subject: [PATCH 1/2] parallelize infile --- src/QueryPipeline/QueryPipeline.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/QueryPipeline/QueryPipeline.cpp b/src/QueryPipeline/QueryPipeline.cpp index 9a836f68da1..4250e9c21a3 100644 --- a/src/QueryPipeline/QueryPipeline.cpp +++ b/src/QueryPipeline/QueryPipeline.cpp @@ -353,7 +353,8 @@ 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); } From 4cc013b9180d9efd7c58cc75c1e3929f2a2e90b0 Mon Sep 17 00:00:00 2001 From: Max Kainov Date: Wed, 13 Sep 2023 16:35:56 +0000 Subject: [PATCH 2/2] fix formatting --- src/QueryPipeline/QueryPipeline.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/QueryPipeline/QueryPipeline.cpp b/src/QueryPipeline/QueryPipeline.cpp index 4250e9c21a3..1ad3ddf9d6f 100644 --- a/src/QueryPipeline/QueryPipeline.cpp +++ b/src/QueryPipeline/QueryPipeline.cpp @@ -354,7 +354,7 @@ QueryPipeline::QueryPipeline(Pipe pipe) 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); }