1#pragma once
2
3#include <vector>
4
5#include <Processors/IProcessor.h>
6
7
8namespace 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