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

Fix distinct after JOIN or UNION

Browse Source
This commit is contained in:
Igor Nikonov 2023-01-26 21:53:08 +00:00
parent eea076cee0
commit 60a69d4689
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Processors/QueryPlan/Optimizations/removeRedundantDistinct.cpp
View File

@ -1,8 +1,10 @@
#include <memory>
#include <Processors/QueryPlan/DistinctStep.h>
#include <Processors/QueryPlan/JoinStep.h>
#include <Processors/QueryPlan/Optimizations/Optimizations.h>
#include <Common/typeid_cast.h>
#include <Processors/QueryPlan/UnionStep.h>
#include <Common/logger_useful.h>
#include <Common/typeid_cast.h>
namespace DB::QueryPlanOptimizations
{
@ -46,10 +48,16 @@ size_t tryRemoveRedundantDistinct(QueryPlan::Node * parent_node, QueryPlan::Node
distinct_node = parent_node->children.front();
DistinctStep * inner_distinct_step = nullptr;
const DistinctStep * inner_distinct_step = nullptr;
QueryPlan::Node * node = distinct_node;
while (!node->children.empty())
{
const IQueryPlanStep* current_step = node->step.get();
/// don't try to remove DISTINCT after union or join
if (typeid_cast<const UnionStep*>(current_step) || typeid_cast<const JoinStep*>(current_step))
break;
node = node->children.front();
inner_distinct_step = typeid_cast<DistinctStep *>(node->step.get());
if (inner_distinct_step)