ClickHouse

1
#include <Processors/QueryPlan/ExtremesStep.h>
2
#include <QueryPipeline/QueryPipelineBuilder.h>
3

4
namespace DB
5
{
6

7
static ITransformingStep::Traits getTraits()
8
{
9
    return ITransformingStep::Traits
10
    {
11
        {
12
            .returns_single_stream = false,
13
            .preserves_number_of_streams = true,
14
            .preserves_sorting = true,
15
        },
16
        {
17
            .preserves_number_of_rows = true,
18
        }
19
    };
20
}
21

22
ExtremesStep::ExtremesStep(const DataStream & input_stream_)
23
    : ITransformingStep(input_stream_, input_stream_.header, getTraits())
24
{
25
}
26

27
void ExtremesStep::transformPipeline(QueryPipelineBuilder & pipeline, const BuildQueryPipelineSettings &)
28
{
29
    pipeline.addExtremesTransform();
30
}
31

32
}
33