This is an automated email from the ASF dual-hosted git repository.
jakevin pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new bc279f0ce7b [test](Nereids): remove test
infer_set_operator_distinct(CBO) (#32547)
bc279f0ce7b is described below
commit bc279f0ce7b5232a62172aee65cb35b820b38a76
Author: jakevin <[email protected]>
AuthorDate: Thu Mar 21 16:11:44 2024 +0800
[test](Nereids): remove test infer_set_operator_distinct(CBO) (#32547)
---
.../infer_set_operator_distinct.out | 372 ---------------------
.../infer_set_operator_distinct.groovy | 172 ----------
2 files changed, 544 deletions(-)
diff --git
a/regression-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out
b/regression-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out
deleted file mode 100644
index 786072eae0d..00000000000
---
a/regression-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out
+++ /dev/null
@@ -1,372 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !union_distinct --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t2]
-
--- !union_complex_conditions --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------filter((t1.score > 10))
-------------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------filter((t2.name = 'Test'))
-------------------PhysicalOlapScan[t2]
-
--- !multi_union --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !except_distinct --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalExcept
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t2]
-
--- !except_with_filter --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalExcept
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------filter((t1.id > 100))
-------------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------filter((t2.id < 50))
-------------PhysicalOlapScan[t2]
-
--- !intersect_distinct --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalIntersect
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t2]
-
--- !intersect_with_aggregate --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalIntersect
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------hashAgg[GLOBAL]
-------------PhysicalDistribute[DistributionSpecGather]
---------------hashAgg[LOCAL]
-----------------PhysicalProject
-------------------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------hashAgg[GLOBAL]
-------------PhysicalDistribute[DistributionSpecGather]
---------------hashAgg[LOCAL]
-----------------PhysicalProject
-------------------PhysicalOlapScan[t2]
-
--- !mixed_set_operators --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalIntersect
-------PhysicalExcept
---------hashAgg[GLOBAL]
-----------PhysicalDistribute[DistributionSpecHash]
-------------hashAgg[LOCAL]
---------------PhysicalUnion
-----------------PhysicalDistribute[DistributionSpecExecutionAny]
-------------------PhysicalProject
---------------------PhysicalOlapScan[t1]
-----------------PhysicalDistribute[DistributionSpecExecutionAny]
-------------------PhysicalProject
---------------------PhysicalOlapScan[t2]
---------PhysicalDistribute[DistributionSpecHash]
-----------PhysicalProject
-------------PhysicalOlapScan[t3]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t4]
-
--- !join_with_union --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id))
otherCondition=()
-------------------PhysicalOlapScan[t1]
-------------------PhysicalDistribute[DistributionSpecHash]
---------------------PhysicalProject
-----------------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !set_operator_with_subquery --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------filter((t1.score > 10))
-------------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------filter((t2.score < 5))
-------------------PhysicalOlapScan[t2]
-
--- !nested_union --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t4]
-
--- !union_order_limit --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalTopN[MERGE_SORT]
-----------------PhysicalDistribute[DistributionSpecGather]
-------------------PhysicalTopN[LOCAL_SORT]
---------------------PhysicalOlapScan[t2]
-
--- !union_inner_join_combination --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id))
otherCondition=()
-------------------PhysicalOlapScan[t1]
-------------------PhysicalDistribute[DistributionSpecHash]
---------------------PhysicalProject
-----------------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !union_left_join_combination --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashJoin[LEFT_OUTER_JOIN] hashCondition=((t1.id = t2.id))
otherCondition=()
-------------------PhysicalOlapScan[t1]
-------------------PhysicalDistribute[DistributionSpecHash]
---------------------PhysicalProject
-----------------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !union_right_join_combination --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashJoin[LEFT_OUTER_JOIN] hashCondition=((t1.id = t2.id))
otherCondition=()
-------------------PhysicalProject
---------------------PhysicalOlapScan[t2]
-------------------PhysicalDistribute[DistributionSpecHash]
---------------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !union_full_join_combination --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalProject
---------------hashJoin[FULL_OUTER_JOIN] hashCondition=((t1.id = t2.id))
otherCondition=()
-----------------PhysicalDistribute[DistributionSpecHash]
-------------------PhysicalOlapScan[t1]
-----------------PhysicalDistribute[DistributionSpecHash]
-------------------PhysicalProject
---------------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !union_left_semi_join_combination --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashJoin[LEFT_SEMI_JOIN] hashCondition=((t1.id = t2.id))
otherCondition=()
-------------------PhysicalOlapScan[t1]
-------------------PhysicalDistribute[DistributionSpecHash]
---------------------PhysicalProject
-----------------------PhysicalOlapScan[t2]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------PhysicalOlapScan[t3]
-
--- !except_with_subquery --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalExcept
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------filter((t2.score > 10))
-------------PhysicalOlapScan[t2]
-
--- !intersect_different_types --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalIntersect
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t2]
-
--- !union_complex_aggregate --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashAgg[GLOBAL]
-------------------PhysicalDistribute[DistributionSpecGather]
---------------------hashAgg[LOCAL]
-----------------------PhysicalProject
-------------------------filter((t1.id > 100))
---------------------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashAgg[GLOBAL]
-------------------PhysicalDistribute[DistributionSpecGather]
---------------------hashAgg[LOCAL]
-----------------------PhysicalProject
-------------------------filter((t2.id < 50))
---------------------------PhysicalOlapScan[t2]
-
--- !union_all_distinct --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalUnion
-------PhysicalDistribute[DistributionSpecExecutionAny]
---------PhysicalProject
-----------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecExecutionAny]
---------PhysicalProject
-----------PhysicalOlapScan[t2]
-
--- !except_complex_subquery --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----PhysicalExcept
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------PhysicalOlapScan[t1]
-------PhysicalDistribute[DistributionSpecHash]
---------PhysicalProject
-----------filter((t2.score > 20))
-------------PhysicalOlapScan[t2]
-
--- !agg_not_output_groupby --
-PhysicalResultSink
---PhysicalDistribute[DistributionSpecGather]
-----hashAgg[GLOBAL]
-------PhysicalDistribute[DistributionSpecHash]
---------hashAgg[LOCAL]
-----------PhysicalUnion
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashAgg[LOCAL]
-------------------PhysicalProject
---------------------PhysicalOlapScan[t1]
-------------PhysicalDistribute[DistributionSpecExecutionAny]
---------------PhysicalProject
-----------------hashAgg[LOCAL]
-------------------PhysicalProject
---------------------PhysicalOlapScan[t2]
-
diff --git
a/regression-test/suites/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.groovy
b/regression-test/suites/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.groovy
deleted file mode 100644
index eb2be5e16d7..00000000000
---
a/regression-test/suites/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.groovy
+++ /dev/null
@@ -1,172 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("test_infer_set_operator_distinct") {
- sql "SET enable_nereids_planner=true"
- sql "set runtime_filter_mode=OFF"
- sql "SET enable_fallback_to_original_planner=false"
-
- sql """
- DROP TABLE IF EXISTS t1;
- """
- sql """
- DROP TABLE IF EXISTS t2;
- """
- sql """
- DROP TABLE IF EXISTS t3;
- """
- sql """
- DROP TABLE IF EXISTS t4;
- """
-
- sql """
- CREATE TABLE IF NOT EXISTS t1(
- `id` int(32) NULL,
- `score` int(64) NULL,
- `name` varchar(64) NULL
- ) ENGINE = OLAP
- DISTRIBUTED BY HASH(id) BUCKETS 4
- PROPERTIES (
- "replication_allocation" = "tag.location.default: 1"
- );
- """
- sql """
- CREATE TABLE IF NOT EXISTS t2(
- `id` int(32) NULL,
- `score` int(64) NULL,
- `name` varchar(64) NULL
- ) ENGINE = OLAP
- DISTRIBUTED BY HASH(id) BUCKETS 4
- PROPERTIES (
- "replication_allocation" = "tag.location.default: 1"
- );
- """
- sql """
- CREATE TABLE IF NOT EXISTS t3(
- `id` int(32) NULL,
- `score` int(64) NULL,
- `name` varchar(64) NULL
- ) ENGINE = OLAP
- DISTRIBUTED BY HASH(id) BUCKETS 4
- PROPERTIES (
- "replication_allocation" = "tag.location.default: 1"
- );
- """
- sql """
- CREATE TABLE IF NOT EXISTS t4(
- `id` int(32) NULL,
- `score` int(64) NULL,
- `name` varchar(64) NULL
- ) ENGINE = OLAP
- DISTRIBUTED BY HASH(id) BUCKETS 4
- PROPERTIES (
- "replication_allocation" = "tag.location.default: 1"
- );
- """
-
- qt_union_distinct """
- explain shape plan select * from t1 union select * from t2;
- """
-
- qt_union_complex_conditions """
- explain shape plan select * from t1 where t1.score > 10 union select *
from t2 where t2.name = 'Test';
- """
-
- qt_multi_union """
- explain shape plan select * from t1 union select * from t2 union
select * from t3;
- """
-
- qt_except_distinct """
- explain shape plan select * from t1 except select * from t2;
- """
-
- qt_except_with_filter """
- explain shape plan select * from t1 where t1.id > 100 except select *
from t2 where t2.id < 50;
- """
-
- qt_intersect_distinct """
- explain shape plan select * from t1 intersect select * from t2;
- """
-
- qt_intersect_with_aggregate """
- explain shape plan select AVG(t1.score) from t1 intersect select
SUM(t2.score) from t2;
- """
-
- qt_mixed_set_operators """
- explain shape plan select * from t1 union select * from t2 except
select * from t3 intersect select * from t4;
- """
-
- qt_join_with_union """
- explain shape plan select t1.* from t1 join t2 on t1.id = t2.id union
select * from t3;
- """
-
- qt_set_operator_with_subquery """
- explain shape plan select * from (select * from t1 where score > 10)
sub1 union select * from (select * from t2 where score < 5) sub2;
- """
-
- qt_nested_union """
- explain shape plan select * from ((select * from t1 union select *
from t2) union (select * from t3 union select * from t4)) sub1;
- """
-
- qt_union_order_limit """
- explain shape plan select * from t1 union select * from t2 order by id
limit 10;
- """
-
- qt_union_inner_join_combination """
- explain shape plan select t1.* from t1 join t2 on t1.id = t2.id union
select * from t3;
- """
-
- qt_union_left_join_combination """
- explain shape plan select t1.* from t1 left join t2 on t1.id = t2.id
union select * from t3;
- """
-
- qt_union_right_join_combination """
- explain shape plan select t1.* from t1 right join t2 on t1.id = t2.id
union select * from t3;
- """
-
- qt_union_full_join_combination """
- explain shape plan select t1.* from t1 full join t2 on t1.id = t2.id
union select * from t3;
- """
-
- qt_union_left_semi_join_combination """
- explain shape plan select t1.* from t1 left semi join t2 on t1.id =
t2.id union select * from t3;
- """
-
- qt_except_with_subquery """
- explain shape plan select * from t1 except select * from (select *
from t2 where score > 10) sub1;
- """
-
- qt_intersect_different_types """
- explain shape plan select name from t1 intersect select name from t2;
- """
-
- qt_union_complex_aggregate """
- explain shape plan select MAX(score) from t1 where id > 100 union
select MIN(score) from t2 where id < 50;
- """
-
- qt_union_all_distinct """
- explain shape plan select * from t1 union all select * from t2;
- """
-
- qt_except_complex_subquery """
- explain shape plan select * from (select id, name from t1) sub1 except
select * from (select id, name from t2 where score > 20) sub2;
- """
-
- qt_agg_not_output_groupby """
- explain shape plan select sum(t1.score) from t1 group by t1.id union
select sum(t2.score) from t2 group by t2.id
- """
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
