Added source steps.

This commit is contained in:
Nikolai Kochetov 2020-06-16 17:14:14 +03:00
parent 4407bd7daa
commit ab452e9391

View File

@ -12,7 +12,7 @@ ReadNothingStep::ReadNothingStep(DataStream output_stream_)
void ReadNothingStep::initializePipeline(QueryPipeline & pipeline)
{
pipeline.init(Pipe(std::make_shared<NullSource>(output_stream.header)));
pipeline.init(Pipe(std::make_shared<NullSource>(getOutputStream().header)));
}
}