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

Set pipeline type in join step description

Browse Source
This commit is contained in:
vdimir 2022-12-23 11:30:22 +00:00
parent 37da8e206b
commit a881a61e74
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Planner/PlannerJoinTree.cpp
View File

@ -586,6 +586,7 @@ QueryPlan buildQueryPlanForJoinNode(QueryTreeNodePtr join_tree_node,
size_t max_block_size = query_context->getSettingsRef().max_block_size; size_t max_block_size = query_context->getSettingsRef().max_block_size;
size_t max_streams = query_context->getSettingsRef().max_threads; size_t max_streams = query_context->getSettingsRef().max_threads;
JoinPipelineType join_pipeline_type = join_algorithm->pipelineType();
auto join_step = std::make_unique<JoinStep>( auto join_step = std::make_unique<JoinStep>(
left_plan.getCurrentDataStream(), left_plan.getCurrentDataStream(),
right_plan.getCurrentDataStream(), right_plan.getCurrentDataStream(),
@ -594,7 +595,7 @@ QueryPlan buildQueryPlanForJoinNode(QueryTreeNodePtr join_tree_node,
max_streams, max_streams,
false /*optimize_read_in_order*/); false /*optimize_read_in_order*/);
join_step->setStepDescription(fmt::format("JOIN {}", JoinPipelineType::FillRightFirst)); join_step->setStepDescription(fmt::format("JOIN {}", join_pipeline_type));
std::vector<QueryPlanPtr> plans; std::vector<QueryPlanPtr> plans;
plans.emplace_back(std::make_unique<QueryPlan>(std::move(left_plan))); plans.emplace_back(std::make_unique<QueryPlan>(std::move(left_plan)));