1 | #pragma once |
2 | |
3 | #include <vector> |
4 | |
5 | #include <Processors/IProcessor.h> |
6 | |
7 | |
8 | namespace DB |
9 | { |
10 | |
11 | /** Wraps pipeline in a single processor. |
12 | * This processor has no inputs and outputs and just executes the pipeline, |
13 | * performing all synchronous work from the current thread. |
14 | */ |
15 | //class SequentialPipelineExecutor : public IProcessor |
16 | //{ |
17 | //private: |
18 | // Processors processors; |
19 | // IProcessor * current_processor = nullptr; |
20 | // |
21 | //public: |
22 | // SequentialPipelineExecutor(const Processors & processors); |
23 | // |
24 | // String getName() const override { return "SequentialPipelineExecutor"; } |
25 | // |
26 | // Status prepare() override; |
27 | // void work() override; |
28 | // void schedule(EventCounter & watch) override; |
29 | //}; |
30 | |
31 | } |
32 | |