Not everything at once

This commit is contained in:
alesapin 2024-11-25 13:25:55 +01:00
parent d478a1dc0e
commit b64700cfa8

View File

@ -11,7 +11,7 @@
#include <Processors/Transforms/PlanSquashingTransform.h> #include <Processors/Transforms/PlanSquashingTransform.h>
#include <Processors/Transforms/SquashingTransform.h> #include <Processors/Transforms/SquashingTransform.h>
#include <Processors/Transforms/ExpressionTransform.h> #include <Processors/Transforms/ExpressionTransform.h>
#include <Processors/Executors/PullingAsyncPipelineExecutor.h> #include <Processors/Executors/PullingPipelineExecutor.h>
#include <Storages/LiveView/StorageLiveView.h> #include <Storages/LiveView/StorageLiveView.h>
#include <Storages/WindowView/StorageWindowView.h> #include <Storages/WindowView/StorageWindowView.h>
#include <Storages/MergeTree/ReplicatedMergeTreeSink.h> #include <Storages/MergeTree/ReplicatedMergeTreeSink.h>
@ -148,7 +148,7 @@ private:
struct State struct State
{ {
QueryPipeline pipeline; QueryPipeline pipeline;
PullingAsyncPipelineExecutor executor; PullingPipelineExecutor executor;
explicit State(QueryPipeline pipeline_) explicit State(QueryPipeline pipeline_)
: pipeline(std::move(pipeline_)) : pipeline(std::move(pipeline_))