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

Fixing some tests.

Browse Source
This commit is contained in:
Nikolai Kochetov 2024-11-29 12:49:19 +00:00
parent 638e94fb39
commit e7d19bef2a
4 changed files with 4 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Processors/QueryPlan/Optimizations/optimizeFilterByJoinSet.cpp
View File

@ -134,6 +134,9 @@ void optimizeFilterByJoinSet(QueryPlan::Node & node)
if (table_join.kind() != JoinKind::Inner && table_join.kind() != JoinKind::Right)
return;
if (table_join.strictness() != JoinStrictness::Any && table_join.strictness() != JoinStrictness::All && table_join.strictness() != JoinStrictness::Semi)
return;
const auto & clauses = table_join.getClauses();
if (clauses.empty())
return;

15
tests/queries/0_stateless/02835_join_step_explain.reference
View File

@ -21,12 +21,6 @@ Positions: 4 0 2 1
Strictness: ALL
Algorithm: ConcurrentHashJoin
Clauses: [(__table1.id) = (__table2.id)]
Dynamic Filter
Actions: INPUT : 0 -> id UInt64 : 0
COLUMN Const(Set) -> Set : 1
ALIAS id :: 0 -> __table1.id UInt64 : 2
FUNCTION in(__table1.id :: 2, :: 1) -> in(__table1.id, ) UInt8 : 0
Positions: 0
Expression ((JOIN actions + Change column names to column identifiers))
Header: __table1.id UInt64
__table1.value_1 String
@ -84,15 +78,6 @@ Positions: 6 0 3 1
Algorithm: HashJoin
ASOF inequality: LESS
Clauses: [(__table1.id, __table1.value_2) = (__table2.id, __table2.value_2)]
Dynamic Filter
Actions: INPUT : 0 -> id UInt64 : 0
INPUT : 1 -> value_2 UInt64 : 1
COLUMN Const(Set) -> Set : 2
ALIAS id :: 0 -> __table1.id UInt64 : 3
ALIAS value_2 :: 1 -> __table1.value_2 UInt64 : 0
FUNCTION tuple(__table1.id :: 3, __table1.value_2 :: 0) -> tuple(__table1.id, __table1.value_2) Tuple(UInt64, UInt64) : 1
FUNCTION in(tuple(__table1.id, __table1.value_2) :: 1, :: 2) -> in(tuple(__table1.id, __table1.value_2), ) UInt8 : 0
Positions: 0
Expression ((JOIN actions + Change column names to column identifiers))
Header: __table1.id UInt64
__table1.value_1 String

18
tests/queries/0_stateless/03036_join_filter_push_down_equivalent_sets.reference
View File

@ -26,12 +26,6 @@ Positions: 4 2 0 1
Strictness: ALL
Algorithm: ConcurrentHashJoin
Clauses: [(__table1.id) = (__table2.id)]
Dynamic Filter
Actions: INPUT : 0 -> id UInt64 : 0
COLUMN Const(Set) -> Set : 1
ALIAS id :: 0 -> __table1.id UInt64 : 2
FUNCTION in(__table1.id :: 2, :: 1) -> in(__table1.id, ) UInt8 : 0
Positions: 0
Filter (( + (JOIN actions + Change column names to column identifiers)))
Header: __table1.id UInt64
__table1.value String
@ -99,12 +93,6 @@ Positions: 4 2 0 1
Strictness: ALL
Algorithm: ConcurrentHashJoin
Clauses: [(__table1.id) = (__table2.id)]
Dynamic Filter
Actions: INPUT : 0 -> id UInt64 : 0
COLUMN Const(Set) -> Set : 1
ALIAS id :: 0 -> __table1.id UInt64 : 2
FUNCTION in(__table1.id :: 2, :: 1) -> in(__table1.id, ) UInt8 : 0
Positions: 0
Filter (( + (JOIN actions + Change column names to column identifiers)))
Header: __table1.id UInt64
__table1.value String
@ -172,12 +160,6 @@ Positions: 4 2 0 1
Strictness: ALL
Algorithm: ConcurrentHashJoin
Clauses: [(__table1.id) = (__table2.id)]
Dynamic Filter
Actions: INPUT : 0 -> id UInt64 : 0
COLUMN Const(Set) -> Set : 1
ALIAS id :: 0 -> __table1.id UInt64 : 2
FUNCTION in(__table1.id :: 2, :: 1) -> in(__table1.id, ) UInt8 : 0
Positions: 0
Filter (( + (JOIN actions + Change column names to column identifiers)))
Header: __table1.id UInt64
__table1.value String

1
tests/queries/0_stateless/03036_join_filter_push_down_equivalent_sets.sql
View File

@ -1,6 +1,7 @@
SET enable_analyzer = 1;
SET optimize_move_to_prewhere = 0;
SET query_plan_convert_outer_join_to_inner_join = 0;
SET merge_tree_read_split_ranges_into_intersecting_and_non_intersecting_injection_probability=0;
DROP TABLE IF EXISTS test_table_1;
CREATE TABLE test_table_1