1#include <Processors/ISimpleTransform.h>
2
3namespace DB
4{
5
6class ExtremesTransform : public ISimpleTransform
7{
8
9public:
10 explicit ExtremesTransform(const Block & header);
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
19protected:
20 void transform(Chunk & chunk) override;
21
22 bool finished_transform = false;
23 Chunk extremes;
24
25private:
26 MutableColumns extremes_columns;
27};
28
29}
30
31