(Nereids): remove test infer_set_operator_distinct(CBO)
This commit is contained in:
jackwener
@ -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]
|
||||
|
||||
@ -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
|
||||
"""
|
||||
}
|
||||
Reference in New Issue
Block a user