thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-18 21:51:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-09-16 19:30:48 +03:00
parent 8a26251f94
commit 2f7ab2bca4
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Processors/QueryPipeline.cpp
View File

@ -263,15 +263,15 @@ QueryPipeline QueryPipeline::unitePipelines(
}
void QueryPipeline::addCreatingSetsTransform()
void QueryPipeline::addCreatingSetsTransform(SubqueryForSet subquery_for_set, const SizeLimits & limits, const Context & context)
{
pipeline.resize(1);
resize(1);
auto transform = std::make_shared<CreatingSetsTransform>(
pipeline.getHeader(),
getOutputStream().header,
std::move(subquery_for_set),
network_transfer_limits,
limits,
context));
InputPort * totals_port = nullptr;

4
src/Processors/QueryPipeline.h
View File

@ -26,6 +26,8 @@ class QueryPlan;
struct SubqueryForSet;
using SubqueriesForSets = std::unordered_map<String, SubqueryForSet>;
struct SizeLimits;
class QueryPipeline
{
public:
@ -89,7 +91,7 @@ public:
/// Pipeline must have same header.
void addDelayingPipeline(QueryPipeline pipeline);
void addCreatingSetsTransform();
void addCreatingSetsTransform(SubqueryForSet subquery_for_set, const SizeLimits & limits, const Context & context);
PipelineExecutorPtr execute();

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

@ -39,7 +39,7 @@ CreatingSetStep::CreatingSetStep(
void CreatingSetStep::transformPipeline(QueryPipeline & pipeline)
{
pipeline.addCreatingSetsTransform();
pipeline.addCreatingSetsTransform(std::move(subquery_for_set), network_transfer_limits, context);
}
void CreatingSetStep::describeActions(FormatSettings & settings) const