1 | #include <Processors/ISimpleTransform.h> |
2 | |
3 | namespace DB |
4 | { |
5 | |
6 | class ExtremesTransform : public ISimpleTransform |
7 | { |
8 | |
9 | public: |
10 | explicit ExtremesTransform(const Block & ); |
11 | |
12 | String getName() const override { return "ExtremesTransform" ; } |
13 | |
14 | OutputPort & getExtremesPort() { return outputs.back(); } |
15 | |
16 | Status prepare() override; |
17 | void work() override; |
18 | |
19 | protected: |
20 | void transform(Chunk & chunk) override; |
21 | |
22 | bool finished_transform = false; |
23 | Chunk extremes; |
24 | |
25 | private: |
26 | MutableColumns extremes_columns; |
27 | }; |
28 | |
29 | } |
30 | |
31 | |