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

Better

Browse Source
This commit is contained in:
Amos Bird 2022-07-07 23:00:40 +08:00
parent d3709c6c26
commit 982e1a73d3
No known key found for this signature in database
GPG Key ID: 80D430DCBECFEDB4
3 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -38,7 +38,14 @@ QueryPipelineBuilderPtr JoinStep::updatePipeline(QueryPipelineBuilders pipelines
std::move(pipelines[0]), std::move(pipelines[1]), join, output_stream->header, max_block_size, &processors);
return QueryPipelineBuilder::joinPipelinesRightLeft(
std::move(pipelines[0]), std::move(pipelines[1]), join, max_block_size, max_streams, keep_left_read_in_order, &processors);
std::move(pipelines[0]),
std::move(pipelines[1]),
join,
output_stream->header,
max_block_size,
max_streams,
keep_left_read_in_order,
&processors);
}
void JoinStep::describePipeline(FormatSettings & settings) const

2
src/QueryPipeline/QueryPipelineBuilder.cpp
View File

@ -361,6 +361,7 @@ std::unique_ptr<QueryPipelineBuilder> QueryPipelineBuilder::joinPipelinesRightLe
std::unique_ptr<QueryPipelineBuilder> left,
std::unique_ptr<QueryPipelineBuilder> right,
JoinPtr join,
const Block & output_header,
size_t max_block_size,
size_t max_streams,
bool keep_left_read_in_order,
@ -448,7 +449,6 @@ std::unique_ptr<QueryPipelineBuilder> QueryPipelineBuilder::joinPipelinesRightLe
auto lit = left->pipe.output_ports.begin();
auto rit = right->pipe.output_ports.begin();
auto output_header = JoiningTransform::transformHeader(left->getHeader(), join);
for (size_t i = 0; i < num_streams; ++i)
{
auto joining = std::make_shared<JoiningTransform>(

1
src/QueryPipeline/QueryPipelineBuilder.h
View File

@ -114,6 +114,7 @@ public:
std::unique_ptr<QueryPipelineBuilder> left,
std::unique_ptr<QueryPipelineBuilder> right,
JoinPtr join,
const Block & output_header,
size_t max_block_size,
size_t max_streams,
bool keep_left_read_in_order,