blob: 57ccef077aaec456fe1d9924bc15b11d0cca5152 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
#pragma once
#include <Processors/QueryPlan/ITransformingStep.h>
namespace DB
{
/// Calculate extremes. Add special port for extremes.
class ExtremesStep : public ITransformingStep
{
public:
explicit ExtremesStep(const DataStream & input_stream_);
String getName() const override { return "Extremes"; }
void transformPipeline(QueryPipelineBuilder & pipeline, const BuildQueryPipelineSettings &) override;
private:
void updateOutputStream() override
{
output_stream = createOutputStream(input_streams.front(), input_streams.front().header, getDataStreamTraits());
}
};
}
|
