ClickHouse

1
#include <Processors/QueryPlan/ReadNothingStep.h>
2
#include <QueryPipeline/QueryPipelineBuilder.h>
3
#include <Processors/Sources/NullSource.h>
4

5
namespace DB
6
{
7

8
ReadNothingStep::ReadNothingStep(Block output_header)
9
    : ISourceStep(DataStream{.header = std::move(output_header), .has_single_port = true})
10
{
11
}
12

13
void ReadNothingStep::initializePipeline(QueryPipelineBuilder & pipeline, const BuildQueryPipelineSettings &)
14
{
15
    pipeline.init(Pipe(std::make_shared<NullSource>(getOutputStream().header)));
16
}
17

18
}
19