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

don't squash output for ordinary join for now

Browse Source
This commit is contained in:
Nikita Taranov 2024-11-17 15:36:22 +01:00
parent ab6e49b930
commit d0842ee937
2 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Processors/QueryPlan/JoinStep.cpp
View File

@ -80,8 +80,11 @@ QueryPipelineBuilderPtr JoinStep::updatePipeline(QueryPipelineBuilders pipelines
keep_left_read_in_order,
&processors);
pipeline->addSimpleTransform([&](const Block & header)
{ return std::make_shared<SimpleSquashingChunksTransform>(header, 0, min_block_size_bytes); });
if (join->supportParallelJoin())
{
pipeline->addSimpleTransform([&](const Block & header)
{ return std::make_shared<SimpleSquashingChunksTransform>(header, 0, min_block_size_bytes); });
}
return pipeline;
}

19
tests/queries/0_stateless/02236_explain_pipeline_join.reference
View File

@ -1,18 +1,17 @@
(Expression)
ExpressionTransform
(Join)
SimpleSquashingTransform
JoiningTransform 2 → 1
(Expression)
JoiningTransform 2 → 1
(Expression)
ExpressionTransform
(Limit)
Limit
(ReadFromSystemNumbers)
NumbersRange 0 → 1
(Expression)
FillingRightJoinSide
ExpressionTransform
(Limit)
Limit
(ReadFromSystemNumbers)
NumbersRange 0 → 1
(Expression)
FillingRightJoinSide
ExpressionTransform
(Limit)
Limit
(ReadFromSystemNumbers)
NumbersRange 0 → 1