thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 09:32:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

FillingNoopTransform for totals stream

Browse Source
This commit is contained in:
Igor Nikonov 2023-03-13 21:39:20 +00:00
parent 85b0c5a1a4
commit 4239bfb586
2 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/QueryPlan/FillingStep.cpp
View File

@ -41,7 +41,7 @@ void FillingStep::transformPipeline(QueryPipelineBuilder & pipeline, const Build
pipeline.addSimpleTransform([&](const Block & header, QueryPipelineBuilder::StreamType stream_type) -> ProcessorPtr
{
if (stream_type == QueryPipelineBuilder::StreamType::Totals)
return nullptr;
return std::make_shared<FillingNoopTransform>(header, sort_description);
return std::make_shared<FillingTransform>(header, sort_description, std::move(interpolate_description));
});

13
src/Processors/Transforms/FillingTransform.h
View File

@ -52,4 +52,17 @@ private:
bool should_insert_first = false;
};
class FillingNoopTransform : public ISimpleTransform
{
public:
FillingNoopTransform(const Block & header, const SortDescription & sort_description_)
: ISimpleTransform(header, FillingTransform::transformHeader(header, sort_description_), true)
{
}
void transform(Chunk &) override {}
String getName() const override { return "FillingNoopTransform"; }
};
}