thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Simple renaming

Browse Source
This commit is contained in:
Igor Nikonov 2024-06-05 11:56:12 +00:00
parent f39dbac9a0
commit 3210d0f471
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Processors/QueryPlan/ParallelReplicasLocalPlan.cpp
View File

@ -232,7 +232,7 @@ std::unique_ptr<QueryPlan> createLocalPlanForParallelReplicas(
ContextPtr context,
QueryProcessingStage::Enum processed_stage,
ParallelReplicasReadingCoordinatorPtr coordinator,
QueryPlanStepPtr read_from_merge_tree,
QueryPlanStepPtr analyzed_read_from_merge_tree,
bool has_missing_objects)
{
checkStackSize();
@ -273,10 +273,10 @@ std::unique_ptr<QueryPlan> createLocalPlanForParallelReplicas(
}
chassert(reading);
if (!read_from_merge_tree)
read_from_merge_tree = std::move(node->step);
if (!analyzed_read_from_merge_tree)
analyzed_read_from_merge_tree = std::move(node->step);
auto * analyzed_merge_tree = typeid_cast<ReadFromMergeTree *>(read_from_merge_tree.get());
auto * analyzed_merge_tree = typeid_cast<ReadFromMergeTree *>(analyzed_read_from_merge_tree.get());
/// if no analysis is done yet, let's do it (happens with JOINs)
if (!analyzed_merge_tree->hasAnalyzedResult())
analyzed_merge_tree->setAnalyzedResult(analyzed_merge_tree->selectRangesToRead());