database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhancement](Nereids): add phase in shape string (#26682)

Browse Source
This commit is contained in:
谢健
2023-11-10 14:56:28 +08:00
committed by GitHub
parent 5c3fed216d
commit ce64f0c917
233 changed files with 568 additions and 553 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalLimit.java
View File

@ -164,6 +164,11 @@ public class PhysicalLimit<CHILD_TYPE extends Plan> extends PhysicalUnary<CHILD_
);
}
@Override
public String shapeInfo() {
return this.getClass().getSimpleName() + "[" + phase + "]";
}
@Override
public List<Slot> computeOutput() {
return child().getOutput();

5
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalQuickSort.java
View File

@ -99,6 +99,11 @@ public class PhysicalQuickSort<CHILD_TYPE extends Plan> extends AbstractPhysical
statistics, child());
}
@Override
public String shapeInfo() {
return this.getClass().getSimpleName() + "[" + phase + "]";
}
@Override
public String toString() {
return Utils.toSqlString("PhysicalQuickSort[" + id.asInt() + "]" + getGroupIdWithPrefix(),

5
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalTopN.java
View File

@ -147,6 +147,11 @@ public class PhysicalTopN<CHILD_TYPE extends Plan> extends AbstractPhysicalSort<
groupExpression, getLogicalProperties(), physicalProperties, statistics, child());
}
@Override
public String shapeInfo() {
return this.getClass().getSimpleName() + "[" + phase + "]";
}
@Override
public String toString() {
return Utils.toSqlString("PhysicalTopN[" + id.asInt() + "]" + getGroupIdWithPrefix(),

4
regression-test/data/nereids_hint_tpch_p0/shape/q1.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q10.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q12.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q13.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q16.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q3.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[LOCAL]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((lineitem.l_orderkey = orders.o_orderkey))otherCondition=()

4
regression-test/data/nereids_hint_tpch_p0/shape/q4.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q5.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_hint_tpch_p0/shape/q9.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_p0/cte/test_cte_filter_pushdown.out
View File

@ -3,7 +3,7 @@
PhysicalCteAnchor ( cteId=CTEId#0 )
--PhysicalCteProducer ( cteId=CTEId#0 )
----PhysicalWindow
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------PhysicalProject
----------filter((main.k1 = 1))
------------PhysicalOlapScan[test]
@ -25,7 +25,7 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
----PhysicalProject
------filter((main.k1 = 1))
--------PhysicalWindow
----------PhysicalQuickSort
----------PhysicalQuickSort[LOCAL_SORT]
------------PhysicalDistribute
--------------PhysicalProject
----------------PhysicalOlapScan[test]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q2.1.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q2.2.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q2.3.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q3.1.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q3.2.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q3.3.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q3.4.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q4.1.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q4.2.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_ssb_shape_sf100_p0/shape/q4.3.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

6
regression-test/data/nereids_syntax_p0/push_filter_through_ptopn.out
View File

@ -8,7 +8,7 @@ PhysicalResultSink
--PhysicalDistribute
----filter((rn <= 2))
------PhysicalWindow
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalPartitionTopN
------------PhysicalProject
--------------filter((T.a = 1))
@ -24,7 +24,7 @@ PhysicalResultSink
----PhysicalProject
------filter((rn <= 2))
--------PhysicalWindow
----------PhysicalQuickSort
----------PhysicalQuickSort[LOCAL_SORT]
------------PhysicalPartitionTopN
--------------filter((T.a = 1))
----------------PhysicalOlapScan[push_filter_through_ptopn_tbl]
@ -34,7 +34,7 @@ PhysicalResultSink
--PhysicalDistribute
----filter((T.b = 2) and (rn <= 2))
------PhysicalWindow
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalPartitionTopN
------------PhysicalOlapScan[push_filter_through_ptopn_tbl]

8
regression-test/data/nereids_syntax_p0/push_filter_through_window.out
View File

@ -7,7 +7,7 @@
PhysicalResultSink
--PhysicalDistribute
----PhysicalWindow
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------PhysicalProject
----------filter((T.a = 1))
------------PhysicalOlapScan[push_filter_through_window_tbl]
@ -21,7 +21,7 @@ PhysicalResultSink
--PhysicalDistribute
----PhysicalProject
------PhysicalWindow
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------filter((T.a = 1))
------------PhysicalOlapScan[push_filter_through_window_tbl]
@ -30,7 +30,7 @@ PhysicalResultSink
--PhysicalDistribute
----filter((T.b = 2))
------PhysicalWindow
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalOlapScan[push_filter_through_window_tbl]
-- !5 --
@ -39,7 +39,7 @@ PhysicalResultSink
----PhysicalProject
------filter((T.b = 2))
--------PhysicalWindow
----------PhysicalQuickSort
----------PhysicalQuickSort[LOCAL_SORT]
------------PhysicalDistribute
--------------PhysicalProject
----------------PhysicalOlapScan[push_filter_through_window_tbl]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query1.out
View File

@ -15,9 +15,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------filter((date_dim.d_year = 2000))
----------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((ctr1.ctr_customer_sk = customer.c_customer_sk))otherCondition=()
--------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query10.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_10 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------hashAgg[GLOBAL]
------------PhysicalDistribute
--------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query11.out
View File

@ -38,9 +38,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------PhysicalProject
----------------------PhysicalOlapScan[customer]
--PhysicalResultSink
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((t_s_firstyear.customer_id = t_w_secyear.customer_id))otherCondition=((if((year_total > 0.00), (cast(year_total as DOUBLE) / cast(year_total as DOUBLE)), 0) > if((year_total > 0.00), (cast(year_total as DOUBLE) / cast(year_total as DOUBLE)), 0)))
--------------PhysicalProject

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query12.out
View File

@ -1,12 +1,12 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_12 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------PhysicalWindow
------------PhysicalQuickSort
------------PhysicalQuickSort[LOCAL_SORT]
--------------PhysicalDistribute
----------------hashAgg[GLOBAL]
------------------PhysicalDistribute

8
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query14.out
View File

@ -87,9 +87,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
----------------------filter((date_dim.d_year <= 2001) and (date_dim.d_year >= 1999))
------------------------PhysicalOlapScan[date_dim]
----PhysicalResultSink
------PhysicalTopN
------PhysicalTopN[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalTopN
----------PhysicalTopN[LOCAL_SORT]
------------PhysicalProject
--------------hashAgg[GLOBAL]
----------------PhysicalDistribute
@ -254,9 +254,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
----------------------filter((date_dim.d_year <= 2001) and (date_dim.d_year >= 1999))
------------------------PhysicalOlapScan[date_dim]
----PhysicalResultSink
------PhysicalTopN
------PhysicalTopN[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalTopN
----------PhysicalTopN[LOCAL_SORT]
------------hashJoin[INNER_JOIN] hashCondition=((ty_brand = ly_brand) and (ty_category = ly_category) and (ty_class = ly_class))otherCondition=()
--------------PhysicalProject
----------------NestedLoopJoin[INNER_JOIN](cast(ty_sales as DOUBLE) > cast(average_sales as DOUBLE))

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query15.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_15 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query16.out
View File

@ -1,8 +1,8 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_16 --
PhysicalResultSink
--PhysicalTopN
----PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalTopN[LOCAL_SORT]
------hashAgg[DISTINCT_GLOBAL]
--------PhysicalDistribute
----------hashAgg[DISTINCT_LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query17.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_17 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------hashAgg[GLOBAL]
------------PhysicalDistribute
--------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query18.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_18 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query19.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_19 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query2.out
View File

@ -18,9 +18,9 @@ PhysicalCteAnchor ( cteId=CTEId#1 )
----------------PhysicalProject
------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalQuickSort
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((expr_cast(d_week_seq1 as BIGINT) = expr_(d_week_seq2 - 53)))otherCondition=()
--------------PhysicalDistribute

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query20.out
View File

@ -1,12 +1,12 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_20 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------PhysicalWindow
------------PhysicalQuickSort
------------PhysicalQuickSort[LOCAL_SORT]
--------------PhysicalDistribute
----------------hashAgg[GLOBAL]
------------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query21.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_21 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------filter((if((inv_before > 0), (cast(inv_after as DOUBLE) / cast(inv_before as DOUBLE)), NULL) <= 1.5) and (if((inv_before > 0), (cast(inv_after as DOUBLE) / cast(inv_before as DOUBLE)), NULL) >= cast((2.000000 / 3.0) as DOUBLE)))
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query22.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_22 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

8
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query23.out
View File

@ -54,8 +54,8 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------------------PhysicalProject
--------------------------------PhysicalOlapScan[customer]
----PhysicalResultSink
------PhysicalLimit
--------PhysicalLimit
------PhysicalLimit[GLOBAL]
--------PhysicalLimit[LOCAL]
----------hashAgg[GLOBAL]
------------PhysicalDistribute
--------------hashAgg[LOCAL]
@ -148,9 +148,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------------------PhysicalProject
--------------------------------PhysicalOlapScan[customer]
----PhysicalResultSink
------PhysicalTopN
------PhysicalTopN[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalTopN
----------PhysicalTopN[LOCAL_SORT]
------------PhysicalUnion
--------------hashAgg[GLOBAL]
----------------PhysicalDistribute

8
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query24.out
View File

@ -36,9 +36,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalProject
--------------------PhysicalOlapScan[store_returns]
--PhysicalResultSink
----PhysicalQuickSort
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------NestedLoopJoin[INNER_JOIN](cast(paid as DOUBLE) > cast((0.05 * avg(cast(netpaid as DECIMALV3(38, 4)))) as DOUBLE))
--------------hashAgg[GLOBAL]
@ -94,9 +94,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalProject
--------------------PhysicalOlapScan[store_returns]
--PhysicalResultSink
----PhysicalQuickSort
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------NestedLoopJoin[INNER_JOIN](cast(paid as DOUBLE) > cast((0.05 * avg(cast(netpaid as DECIMALV3(38, 4)))) as DOUBLE))
--------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query25.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_25 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query26.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_26 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query27.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_27 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashAgg[GLOBAL]
--------------PhysicalDistribute

24
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query28.out
View File

@ -1,19 +1,19 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_28 --
PhysicalResultSink
--PhysicalLimit
----PhysicalLimit
--PhysicalLimit[GLOBAL]
----PhysicalLimit[LOCAL]
------PhysicalProject
--------NestedLoopJoin[CROSS_JOIN]
----------PhysicalLimit
----------PhysicalLimit[LOCAL]
------------NestedLoopJoin[CROSS_JOIN]
--------------PhysicalLimit
--------------PhysicalLimit[LOCAL]
----------------NestedLoopJoin[CROSS_JOIN]
------------------PhysicalLimit
------------------PhysicalLimit[LOCAL]
--------------------NestedLoopJoin[CROSS_JOIN]
----------------------PhysicalLimit
----------------------PhysicalLimit[LOCAL]
------------------------NestedLoopJoin[CROSS_JOIN]
--------------------------PhysicalLimit
--------------------------PhysicalLimit[LOCAL]
----------------------------hashAgg[GLOBAL]
------------------------------PhysicalDistribute
--------------------------------hashAgg[LOCAL]
@ -21,7 +21,7 @@ PhysicalResultSink
------------------------------------filter(((((store_sales.ss_list_price >= 107.00) AND (store_sales.ss_list_price <= 117.00)) OR ((store_sales.ss_coupon_amt >= 1319.00) AND (store_sales.ss_coupon_amt <= 2319.00))) OR ((store_sales.ss_wholesale_cost >= 60.00) AND (store_sales.ss_wholesale_cost <= 80.00))) and (store_sales.ss_quantity <= 5) and (store_sales.ss_quantity >= 0))
--------------------------------------PhysicalOlapScan[store_sales]
--------------------------PhysicalDistribute
----------------------------PhysicalLimit
----------------------------PhysicalLimit[LOCAL]
------------------------------hashAgg[GLOBAL]
--------------------------------PhysicalDistribute
----------------------------------hashAgg[LOCAL]
@ -29,7 +29,7 @@ PhysicalResultSink
--------------------------------------filter(((((store_sales.ss_list_price >= 23.00) AND (store_sales.ss_list_price <= 33.00)) OR ((store_sales.ss_coupon_amt >= 825.00) AND (store_sales.ss_coupon_amt <= 1825.00))) OR ((store_sales.ss_wholesale_cost >= 43.00) AND (store_sales.ss_wholesale_cost <= 63.00))) and (store_sales.ss_quantity <= 10) and (store_sales.ss_quantity >= 6))
----------------------------------------PhysicalOlapScan[store_sales]
----------------------PhysicalDistribute
------------------------PhysicalLimit
------------------------PhysicalLimit[LOCAL]
--------------------------hashAgg[GLOBAL]
----------------------------PhysicalDistribute
------------------------------hashAgg[LOCAL]
@ -37,7 +37,7 @@ PhysicalResultSink
----------------------------------filter(((((store_sales.ss_list_price >= 74.00) AND (store_sales.ss_list_price <= 84.00)) OR ((store_sales.ss_coupon_amt >= 4381.00) AND (store_sales.ss_coupon_amt <= 5381.00))) OR ((store_sales.ss_wholesale_cost >= 57.00) AND (store_sales.ss_wholesale_cost <= 77.00))) and (store_sales.ss_quantity <= 15) and (store_sales.ss_quantity >= 11))
------------------------------------PhysicalOlapScan[store_sales]
------------------PhysicalDistribute
--------------------PhysicalLimit
--------------------PhysicalLimit[LOCAL]
----------------------hashAgg[GLOBAL]
------------------------PhysicalDistribute
--------------------------hashAgg[LOCAL]
@ -45,7 +45,7 @@ PhysicalResultSink
------------------------------filter(((((store_sales.ss_list_price >= 89.00) AND (store_sales.ss_list_price <= 99.00)) OR ((store_sales.ss_coupon_amt >= 3117.00) AND (store_sales.ss_coupon_amt <= 4117.00))) OR ((store_sales.ss_wholesale_cost >= 68.00) AND (store_sales.ss_wholesale_cost <= 88.00))) and (store_sales.ss_quantity <= 20) and (store_sales.ss_quantity >= 16))
--------------------------------PhysicalOlapScan[store_sales]
--------------PhysicalDistribute
----------------PhysicalLimit
----------------PhysicalLimit[LOCAL]
------------------hashAgg[GLOBAL]
--------------------PhysicalDistribute
----------------------hashAgg[LOCAL]
@ -53,7 +53,7 @@ PhysicalResultSink
--------------------------filter(((((store_sales.ss_list_price >= 58.00) AND (store_sales.ss_list_price <= 68.00)) OR ((store_sales.ss_coupon_amt >= 9402.00) AND (store_sales.ss_coupon_amt <= 10402.00))) OR ((store_sales.ss_wholesale_cost >= 38.00) AND (store_sales.ss_wholesale_cost <= 58.00))) and (store_sales.ss_quantity <= 25) and (store_sales.ss_quantity >= 21))
----------------------------PhysicalOlapScan[store_sales]
----------PhysicalDistribute
------------PhysicalLimit
------------PhysicalLimit[LOCAL]
--------------hashAgg[GLOBAL]
----------------PhysicalDistribute
------------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query29.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_29 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query3.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_3 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query30.out
View File

@ -21,9 +21,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalProject
--------------------PhysicalOlapScan[customer_address]
--PhysicalResultSink
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((ctr1.ctr_state = ctr2.ctr_state))otherCondition=((cast(ctr_total_return as DOUBLE) > cast((avg(cast(ctr_total_return as DECIMALV3(38, 4))) * 1.2) as DOUBLE)))
--------------PhysicalProject

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query31.out
View File

@ -39,9 +39,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalProject
--------------------PhysicalOlapScan[customer_address]
----PhysicalResultSink
------PhysicalQuickSort
------PhysicalQuickSort[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalQuickSort
----------PhysicalQuickSort[LOCAL_SORT]
------------PhysicalProject
--------------hashJoin[INNER_JOIN] hashCondition=((ws1.ca_county = ws3.ca_county))otherCondition=((if((web_sales > 0.00), (cast(web_sales as DOUBLE) / cast(web_sales as DOUBLE)), NULL) > if((store_sales > 0.00), (cast(store_sales as DOUBLE) / cast(store_sales as DOUBLE)), NULL)))
----------------PhysicalDistribute

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query32.out
View File

@ -1,15 +1,15 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_32 --
PhysicalResultSink
--PhysicalLimit
----PhysicalLimit
--PhysicalLimit[GLOBAL]
----PhysicalLimit[LOCAL]
------hashAgg[GLOBAL]
--------PhysicalDistribute
----------hashAgg[LOCAL]
------------PhysicalProject
--------------filter((cast(cs_ext_discount_amt as DECIMALV3(38, 5)) > (1.3 * avg(cast(cs_ext_discount_amt as DECIMALV3(9, 4))) OVER(PARTITION BY i_item_sk))))
----------------PhysicalWindow
------------------PhysicalQuickSort
------------------PhysicalQuickSort[LOCAL_SORT]
--------------------PhysicalDistribute
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN] hashCondition=((date_dim.d_date_sk = catalog_sales.cs_sold_date_sk))otherCondition=()

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query33.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_33 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query34.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_34 --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((dn.ss_customer_sk = customer.c_customer_sk))otherCondition=()
------------PhysicalProject

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query35.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_35 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------hashAgg[GLOBAL]
------------PhysicalDistribute
--------------hashAgg[LOCAL]

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query36.out
View File

@ -2,12 +2,12 @@
-- !ds_shape_36 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------PhysicalWindow
--------------PhysicalQuickSort
--------------PhysicalQuickSort[LOCAL_SORT]
----------------PhysicalDistribute
------------------PhysicalProject
--------------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query37.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_37 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query38.out
View File

@ -1,8 +1,8 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_38 --
PhysicalResultSink
--PhysicalLimit
----PhysicalLimit
--PhysicalLimit[GLOBAL]
----PhysicalLimit[LOCAL]
------hashAgg[GLOBAL]
--------PhysicalDistribute
----------hashAgg[LOCAL]

8
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query39.out
View File

@ -24,9 +24,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------PhysicalProject
----------------------PhysicalOlapScan[item]
--PhysicalResultSink
----PhysicalQuickSort
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((inv1.i_item_sk = inv2.i_item_sk) and (inv1.w_warehouse_sk = inv2.w_warehouse_sk))otherCondition=()
--------------PhysicalDistribute
@ -63,9 +63,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------PhysicalProject
----------------------PhysicalOlapScan[item]
--PhysicalResultSink
----PhysicalQuickSort
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((inv1.i_item_sk = inv2.i_item_sk) and (inv1.w_warehouse_sk = inv2.w_warehouse_sk))otherCondition=()
--------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query4.out
View File

@ -55,9 +55,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------PhysicalProject
----------------------PhysicalOlapScan[customer]
--PhysicalResultSink
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((t_s_firstyear.customer_id = t_w_secyear.customer_id))otherCondition=((if((year_total > 0.000000), (cast(year_total as DOUBLE) / cast(year_total as DOUBLE)), NULL) > if((year_total > 0.000000), (cast(year_total as DOUBLE) / cast(year_total as DOUBLE)), NULL)))
--------------PhysicalProject

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query40.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_40 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query41.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_41 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query42.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_42 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query43.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_43 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

12
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query44.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_44 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((asceding.rnk = descending.rnk))otherCondition=()
------------PhysicalDistribute
@ -15,9 +15,9 @@ PhysicalResultSink
--------------------PhysicalProject
----------------------filter((rnk < 11))
------------------------PhysicalWindow
--------------------------PhysicalQuickSort
--------------------------PhysicalQuickSort[MERGE_SORT]
----------------------------PhysicalDistribute
------------------------------PhysicalQuickSort
------------------------------PhysicalQuickSort[LOCAL_SORT]
--------------------------------PhysicalPartitionTopN
----------------------------------PhysicalProject
------------------------------------NestedLoopJoin[INNER_JOIN](cast(rank_col as DOUBLE) > cast((0.9 * rank_col) as DOUBLE))
@ -46,9 +46,9 @@ PhysicalResultSink
------------------PhysicalProject
--------------------filter((rnk < 11))
----------------------PhysicalWindow
------------------------PhysicalQuickSort
------------------------PhysicalQuickSort[MERGE_SORT]
--------------------------PhysicalDistribute
----------------------------PhysicalQuickSort
----------------------------PhysicalQuickSort[LOCAL_SORT]
------------------------------PhysicalPartitionTopN
--------------------------------PhysicalProject
----------------------------------NestedLoopJoin[INNER_JOIN](cast(rank_col as DOUBLE) > cast((0.9 * rank_col) as DOUBLE))

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query45.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_45 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query46.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_46 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((customer.c_current_addr_sk = current_addr.ca_address_sk))otherCondition=(( not (ca_city = bought_city)))
------------PhysicalDistribute

8
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query47.out
View File

@ -4,9 +4,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--PhysicalCteProducer ( cteId=CTEId#0 )
----PhysicalProject
------PhysicalWindow
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalWindow
------------PhysicalQuickSort
------------PhysicalQuickSort[LOCAL_SORT]
--------------PhysicalDistribute
----------------PhysicalProject
------------------hashAgg[GLOBAL]
@ -31,9 +31,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------------------PhysicalOlapScan[item]
--PhysicalResultSink
----PhysicalProject
------PhysicalTopN
------PhysicalTopN[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalTopN
----------PhysicalTopN[LOCAL_SORT]
------------PhysicalProject
--------------hashJoin[INNER_JOIN] hashCondition=((v1.i_brand = v1_lag.i_brand) and (v1.i_category = v1_lag.i_category) and (v1.rn = expr_(rn + 1)) and (v1.s_company_name = v1_lag.s_company_name) and (v1.s_store_name = v1_lag.s_store_name))otherCondition=()
----------------hashJoin[INNER_JOIN] hashCondition=((v1.i_brand = v1_lead.i_brand) and (v1.i_category = v1_lead.i_category) and (v1.rn = expr_(rn - 1)) and (v1.s_company_name = v1_lead.s_company_name) and (v1.s_store_name = v1_lead.s_store_name))otherCondition=()

22
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query49.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_49 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]
@ -12,11 +12,11 @@ PhysicalResultSink
------------------PhysicalProject
--------------------filter(((return_rank <= 10) OR (currency_rank <= 10)))
----------------------PhysicalWindow
------------------------PhysicalQuickSort
------------------------PhysicalQuickSort[LOCAL_SORT]
--------------------------PhysicalWindow
----------------------------PhysicalQuickSort
----------------------------PhysicalQuickSort[MERGE_SORT]
------------------------------PhysicalDistribute
--------------------------------PhysicalQuickSort
--------------------------------PhysicalQuickSort[LOCAL_SORT]
----------------------------------PhysicalProject
------------------------------------hashAgg[GLOBAL]
--------------------------------------PhysicalDistribute
@ -38,11 +38,11 @@ PhysicalResultSink
------------------PhysicalProject
--------------------filter(((return_rank <= 10) OR (currency_rank <= 10)))
----------------------PhysicalWindow
------------------------PhysicalQuickSort
------------------------PhysicalQuickSort[LOCAL_SORT]
--------------------------PhysicalWindow
----------------------------PhysicalQuickSort
----------------------------PhysicalQuickSort[MERGE_SORT]
------------------------------PhysicalDistribute
--------------------------------PhysicalQuickSort
--------------------------------PhysicalQuickSort[LOCAL_SORT]
----------------------------------PhysicalProject
------------------------------------hashAgg[GLOBAL]
--------------------------------------PhysicalDistribute
@ -64,11 +64,11 @@ PhysicalResultSink
------------------PhysicalProject
--------------------filter(((return_rank <= 10) OR (currency_rank <= 10)))
----------------------PhysicalWindow
------------------------PhysicalQuickSort
------------------------PhysicalQuickSort[LOCAL_SORT]
--------------------------PhysicalWindow
----------------------------PhysicalQuickSort
----------------------------PhysicalQuickSort[MERGE_SORT]
------------------------------PhysicalDistribute
--------------------------------PhysicalQuickSort
--------------------------------PhysicalQuickSort[LOCAL_SORT]
----------------------------------PhysicalProject
------------------------------------hashAgg[GLOBAL]
--------------------------------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query5.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_5 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query50.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_50 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

10
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query51.out
View File

@ -1,20 +1,20 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_51 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------filter((web_cumulative > store_cumulative))
------------PhysicalWindow
--------------PhysicalQuickSort
--------------PhysicalQuickSort[LOCAL_SORT]
----------------PhysicalDistribute
------------------PhysicalProject
--------------------hashJoin[FULL_OUTER_JOIN] hashCondition=((web.d_date = store.d_date) and (web.item_sk = store.item_sk))otherCondition=()
----------------------PhysicalDistribute
------------------------PhysicalProject
--------------------------PhysicalWindow
----------------------------PhysicalQuickSort
----------------------------PhysicalQuickSort[LOCAL_SORT]
------------------------------PhysicalDistribute
--------------------------------PhysicalProject
----------------------------------hashAgg[GLOBAL]
@ -31,7 +31,7 @@ PhysicalResultSink
----------------------PhysicalDistribute
------------------------PhysicalProject
--------------------------PhysicalWindow
----------------------------PhysicalQuickSort
----------------------------PhysicalQuickSort[LOCAL_SORT]
------------------------------PhysicalDistribute
--------------------------------PhysicalProject
----------------------------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query52.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_52 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query53.out
View File

@ -1,13 +1,13 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_53 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------filter((if((avg_quarterly_sales > 0.0000), (abs((cast(sum_sales as DOUBLE) - cast(avg_quarterly_sales as DOUBLE))) / cast(avg_quarterly_sales as DOUBLE)), NULL) > 0.1))
------------PhysicalWindow
--------------PhysicalQuickSort
--------------PhysicalQuickSort[LOCAL_SORT]
----------------PhysicalDistribute
------------------PhysicalProject
--------------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query54.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_54 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------hashAgg[GLOBAL]
------------PhysicalDistribute
--------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query55.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_55 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query56.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_56 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

8
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query57.out
View File

@ -4,9 +4,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--PhysicalCteProducer ( cteId=CTEId#0 )
----PhysicalProject
------PhysicalWindow
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalWindow
------------PhysicalQuickSort
------------PhysicalQuickSort[LOCAL_SORT]
--------------PhysicalDistribute
----------------PhysicalProject
------------------hashAgg[GLOBAL]
@ -31,9 +31,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------------------PhysicalOlapScan[item]
--PhysicalResultSink
----PhysicalProject
------PhysicalTopN
------PhysicalTopN[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalTopN
----------PhysicalTopN[LOCAL_SORT]
------------PhysicalProject
--------------hashJoin[INNER_JOIN] hashCondition=((v1.cc_name = v1_lag.cc_name) and (v1.i_brand = v1_lag.i_brand) and (v1.i_category = v1_lag.i_category) and (v1.rn = expr_(rn + 1)))otherCondition=()
----------------hashJoin[INNER_JOIN] hashCondition=((v1.cc_name = v1_lead.cc_name) and (v1.i_brand = v1_lead.i_brand) and (v1.i_category = v1_lead.i_category) and (v1.rn = expr_(rn - 1)))otherCondition=()

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query58.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_58 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((ss_items.item_id = ws_items.item_id))otherCondition=((cast(cs_item_rev as DOUBLE) <= cast((1.1 * ws_item_rev) as DOUBLE)) and (cast(cs_item_rev as DOUBLE) >= cast((0.9 * ws_item_rev) as DOUBLE)) and (cast(ss_item_rev as DOUBLE) <= cast((1.1 * ws_item_rev) as DOUBLE)) and (cast(ss_item_rev as DOUBLE) >= cast((0.9 * ws_item_rev) as DOUBLE)) and (cast(ws_item_rev as DOUBLE) <= cast((1.1 * cs_item_rev) as DOUBLE)) and (cast(ws_item_rev as DOUBLE) <= cast((1.1 * ss_item_rev) as DOUBLE)) and (cast(ws_item_rev as DOUBLE) >= cast((0.9 * cs_item_rev) as DOUBLE)) and (cast(ws_item_rev as DOUBLE) >= cast((0.9 * ss_item_rev) as DOUBLE)))
--------------PhysicalProject

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query59.out
View File

@ -14,9 +14,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalProject
------PhysicalTopN
------PhysicalTopN[MERGE_SORT]
--------PhysicalDistribute
----------PhysicalTopN
----------PhysicalTopN[LOCAL_SORT]
------------PhysicalProject
--------------hashJoin[INNER_JOIN] hashCondition=((expr_cast(d_week_seq1 as BIGINT) = expr_(d_week_seq2 - 52)) and (y.s_store_id1 = x.s_store_id2))otherCondition=()
----------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query6.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_6 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------filter((cnt >= 10))
------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query60.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_60 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query61.out
View File

@ -2,8 +2,8 @@
-- !ds_shape_61 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
------PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalTopN[LOCAL_SORT]
--------NestedLoopJoin[CROSS_JOIN]
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query62.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_62 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query63.out
View File

@ -1,13 +1,13 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_63 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------filter((if((avg_monthly_sales > 0.0000), (abs((cast(sum_sales as DOUBLE) - cast(avg_monthly_sales as DOUBLE))) / cast(avg_monthly_sales as DOUBLE)), NULL) > 0.1))
------------PhysicalWindow
--------------PhysicalQuickSort
--------------PhysicalQuickSort[LOCAL_SORT]
----------------PhysicalDistribute
------------------PhysicalProject
--------------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query64.out
View File

@ -111,9 +111,9 @@ PhysicalCteAnchor ( cteId=CTEId#1 )
------------------PhysicalProject
--------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalQuickSort
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute
--------PhysicalQuickSort
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((cs1.item_sk = cs2.item_sk) and (cs1.store_name = cs2.store_name) and (cs1.store_zip = cs2.store_zip))otherCondition=((cs2.cnt <= cs1.cnt))
--------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query65.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_65 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((item.i_item_sk = sc.ss_item_sk))otherCondition=()
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query66.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_66 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query67.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_67 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------filter((rk <= 100))
----------PhysicalWindow
------------PhysicalPartitionTopN

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query68.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_68 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((customer.c_current_addr_sk = current_addr.ca_address_sk))otherCondition=(( not (ca_city = bought_city)))
------------PhysicalProject

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query69.out
View File

@ -2,9 +2,9 @@
-- !ds_shape_69 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------hashAgg[GLOBAL]
------------PhysicalDistribute
--------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query7.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_7 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

6
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query70.out
View File

@ -2,12 +2,12 @@
-- !ds_shape_70 --
PhysicalResultSink
--PhysicalProject
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------PhysicalWindow
--------------PhysicalQuickSort
--------------PhysicalQuickSort[LOCAL_SORT]
----------------PhysicalDistribute
------------------PhysicalProject
--------------------hashAgg[GLOBAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query71.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_71 --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query72.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_72 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query73.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_73 --
PhysicalResultSink
--PhysicalQuickSort
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute
------PhysicalQuickSort
------PhysicalQuickSort[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((dj.ss_customer_sk = customer.c_customer_sk))otherCondition=()
------------PhysicalProject

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query74.out
View File

@ -31,9 +31,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalDistribute
--------------------PhysicalOlapScan[customer]
--PhysicalResultSink
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((t_s_firstyear.customer_id = t_w_firstyear.customer_id))otherCondition=((if((year_total > 0.00), (cast(year_total as DECIMALV3(13, 8)) / year_total), NULL) > if((year_total > 0.00), (cast(year_total as DECIMALV3(13, 8)) / year_total), NULL)))
--------------hashJoin[INNER_JOIN] hashCondition=((t_s_firstyear.customer_id = t_w_secyear.customer_id))otherCondition=()

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query75.out
View File

@ -67,9 +67,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------------------filter(d_year IN (2001, 2002))
----------------------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalTopN
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute
--------PhysicalTopN
--------PhysicalTopN[LOCAL_SORT]
----------PhysicalProject
------------hashJoin[INNER_JOIN] hashCondition=((curr_yr.i_brand_id = prev_yr.i_brand_id) and (curr_yr.i_category_id = prev_yr.i_category_id) and (curr_yr.i_class_id = prev_yr.i_class_id) and (curr_yr.i_manufact_id = prev_yr.i_manufact_id))otherCondition=(((cast(cast(sales_cnt as DECIMALV3(17, 2)) as DECIMALV3(23, 8)) / cast(sales_cnt as DECIMALV3(17, 2))) < 0.900000))
--------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query76.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_76 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute
------------hashAgg[LOCAL]

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query77.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_77 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query78.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_78 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------filter(((coalesce(ws_qty, 0) > 0) OR (coalesce(cs_qty, 0) > 0)))
------------hashJoin[LEFT_OUTER_JOIN] hashCondition=((cs.cs_customer_sk = ss.ss_customer_sk) and (cs.cs_item_sk = ss.ss_item_sk) and (cs.cs_sold_year = ss.ss_sold_year))otherCondition=()

4
regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query79.out
View File

@ -1,9 +1,9 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !ds_shape_79 --
PhysicalResultSink
--PhysicalTopN
--PhysicalTopN[MERGE_SORT]
----PhysicalDistribute
------PhysicalTopN
------PhysicalTopN[LOCAL_SORT]
--------PhysicalProject
----------hashJoin[INNER_JOIN] hashCondition=((ms.ss_customer_sk = customer.c_customer_sk))otherCondition=()
------------PhysicalDistribute

Some files were not shown because too many files have changed in this diff Show More