Skip to content

Commit 3689297

Browse files
engleflyenglefly
committed
update-shape
1 parent 07b7748 commit 3689297

File tree

22 files changed

+662
-683
lines changed

22 files changed

+662
-683
lines changed

‎regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query23.out

+31-32
Original file line numberDiff line numberDiff line change
@@ -46,36 +46,35 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
4646
--------------------------------filter(d_year IN (2000, 2001, 2002, 2003))
4747
----------------------------------PhysicalOlapScan[date_dim]
4848
----PhysicalResultSink
49-
------PhysicalTopN[MERGE_SORT]
50-
--------PhysicalTopN[LOCAL_SORT]
51-
----------hashAgg[GLOBAL]
52-
------------PhysicalDistribute[DistributionSpecGather]
53-
--------------hashAgg[LOCAL]
54-
----------------PhysicalUnion
55-
------------------PhysicalProject
56-
--------------------hashJoin[RIGHT_SEMI_JOIN shuffle] hashCondition=((catalog_sales.cs_item_sk = frequent_ss_items.item_sk)) otherCondition=() build RFs:RF4 cs_item_sk->[item_sk]
57-
----------------------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF4
58-
----------------------PhysicalProject
59-
------------------------hashJoin[LEFT_SEMI_JOIN shuffle] hashCondition=((catalog_sales.cs_bill_customer_sk = best_ss_customer.c_customer_sk)) otherCondition=()
60-
--------------------------PhysicalProject
61-
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF3 d_date_sk->[cs_sold_date_sk]
62-
------------------------------PhysicalProject
63-
--------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF3
64-
------------------------------PhysicalProject
65-
--------------------------------filter((date_dim.d_moy = 7) and (date_dim.d_year = 2000))
66-
----------------------------------PhysicalOlapScan[date_dim]
67-
--------------------------PhysicalCteConsumer ( cteId=CTEId#2 )
68-
------------------PhysicalProject
69-
--------------------hashJoin[RIGHT_SEMI_JOIN shuffle] hashCondition=((web_sales.ws_item_sk = frequent_ss_items.item_sk)) otherCondition=() build RFs:RF6 ws_item_sk->[item_sk]
70-
----------------------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF6
71-
----------------------PhysicalProject
72-
------------------------hashJoin[LEFT_SEMI_JOIN shuffle] hashCondition=((web_sales.ws_bill_customer_sk = best_ss_customer.c_customer_sk)) otherCondition=()
73-
--------------------------PhysicalProject
74-
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF5 d_date_sk->[ws_sold_date_sk]
75-
------------------------------PhysicalProject
76-
--------------------------------PhysicalOlapScan[web_sales] apply RFs: RF5
77-
------------------------------PhysicalProject
78-
--------------------------------filter((date_dim.d_moy = 7) and (date_dim.d_year = 2000))
79-
----------------------------------PhysicalOlapScan[date_dim]
80-
--------------------------PhysicalCteConsumer ( cteId=CTEId#2 )
49+
------PhysicalTopN[GATHER_SORT]
50+
--------hashAgg[GLOBAL]
51+
----------PhysicalDistribute[DistributionSpecGather]
52+
------------hashAgg[LOCAL]
53+
--------------PhysicalUnion
54+
----------------PhysicalProject
55+
------------------hashJoin[RIGHT_SEMI_JOIN shuffle] hashCondition=((catalog_sales.cs_item_sk = frequent_ss_items.item_sk)) otherCondition=() build RFs:RF4 cs_item_sk->[item_sk]
56+
--------------------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF4
57+
--------------------PhysicalProject
58+
----------------------hashJoin[LEFT_SEMI_JOIN shuffle] hashCondition=((catalog_sales.cs_bill_customer_sk = best_ss_customer.c_customer_sk)) otherCondition=()
59+
------------------------PhysicalProject
60+
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF3 d_date_sk->[cs_sold_date_sk]
61+
----------------------------PhysicalProject
62+
------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF3
63+
----------------------------PhysicalProject
64+
------------------------------filter((date_dim.d_moy = 7) and (date_dim.d_year = 2000))
65+
--------------------------------PhysicalOlapScan[date_dim]
66+
------------------------PhysicalCteConsumer ( cteId=CTEId#2 )
67+
----------------PhysicalProject
68+
------------------hashJoin[RIGHT_SEMI_JOIN shuffle] hashCondition=((web_sales.ws_item_sk = frequent_ss_items.item_sk)) otherCondition=() build RFs:RF6 ws_item_sk->[item_sk]
69+
--------------------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF6
70+
--------------------PhysicalProject
71+
----------------------hashJoin[LEFT_SEMI_JOIN shuffle] hashCondition=((web_sales.ws_bill_customer_sk = best_ss_customer.c_customer_sk)) otherCondition=()
72+
------------------------PhysicalProject
73+
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF5 d_date_sk->[ws_sold_date_sk]
74+
----------------------------PhysicalProject
75+
------------------------------PhysicalOlapScan[web_sales] apply RFs: RF5
76+
----------------------------PhysicalProject
77+
------------------------------filter((date_dim.d_moy = 7) and (date_dim.d_year = 2000))
78+
--------------------------------PhysicalOlapScan[date_dim]
79+
------------------------PhysicalCteConsumer ( cteId=CTEId#2 )
8180

‎regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query32.out

+21-22
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,25 @@
11
-- This file is automatically generated. You should know what you did if you want to edit this
22
-- !ds_shape_32 --
33
PhysicalResultSink
4-
--PhysicalTopN[MERGE_SORT]
5-
----PhysicalTopN[LOCAL_SORT]
6-
------hashAgg[GLOBAL]
7-
--------PhysicalDistribute[DistributionSpecGather]
8-
----------hashAgg[LOCAL]
9-
------------PhysicalProject
10-
--------------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))))
11-
----------------PhysicalWindow
12-
------------------PhysicalQuickSort[LOCAL_SORT]
13-
--------------------PhysicalDistribute[DistributionSpecHash]
14-
----------------------PhysicalProject
15-
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((date_dim.d_date_sk = catalog_sales.cs_sold_date_sk)) otherCondition=() build RFs:RF1 d_date_sk->[cs_sold_date_sk]
16-
--------------------------PhysicalProject
17-
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((item.i_item_sk = catalog_sales.cs_item_sk)) otherCondition=() build RFs:RF0 i_item_sk->[cs_item_sk]
18-
------------------------------PhysicalProject
19-
--------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF0 RF1
20-
------------------------------PhysicalProject
21-
--------------------------------filter((item.i_manufact_id = 722))
22-
----------------------------------PhysicalOlapScan[item]
23-
--------------------------PhysicalProject
24-
----------------------------filter((date_dim.d_date <= '2001-06-07') and (date_dim.d_date >= '2001-03-09'))
25-
------------------------------PhysicalOlapScan[date_dim]
4+
--PhysicalTopN[GATHER_SORT]
5+
----hashAgg[GLOBAL]
6+
------PhysicalDistribute[DistributionSpecGather]
7+
--------hashAgg[LOCAL]
8+
----------PhysicalProject
9+
------------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))))
10+
--------------PhysicalWindow
11+
----------------PhysicalQuickSort[LOCAL_SORT]
12+
------------------PhysicalDistribute[DistributionSpecHash]
13+
--------------------PhysicalProject
14+
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((date_dim.d_date_sk = catalog_sales.cs_sold_date_sk)) otherCondition=() build RFs:RF1 d_date_sk->[cs_sold_date_sk]
15+
------------------------PhysicalProject
16+
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((item.i_item_sk = catalog_sales.cs_item_sk)) otherCondition=() build RFs:RF0 i_item_sk->[cs_item_sk]
17+
----------------------------PhysicalProject
18+
------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF0 RF1
19+
----------------------------PhysicalProject
20+
------------------------------filter((item.i_manufact_id = 722))
21+
--------------------------------PhysicalOlapScan[item]
22+
------------------------PhysicalProject
23+
--------------------------filter((date_dim.d_date <= '2001-06-07') and (date_dim.d_date >= '2001-03-09'))
24+
----------------------------PhysicalOlapScan[date_dim]
2625

‎regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query38.out

+45-46
Original file line numberDiff line numberDiff line change
@@ -1,50 +1,49 @@
11
-- This file is automatically generated. You should know what you did if you want to edit this
22
-- !ds_shape_38 --
33
PhysicalResultSink
4-
--PhysicalTopN[MERGE_SORT]
5-
----PhysicalTopN[LOCAL_SORT]
6-
------hashAgg[GLOBAL]
7-
--------PhysicalDistribute[DistributionSpecGather]
8-
----------hashAgg[LOCAL]
9-
------------PhysicalProject
10-
--------------PhysicalIntersect
11-
----------------PhysicalDistribute[DistributionSpecHash]
12-
------------------hashJoin[INNER_JOIN shuffle] hashCondition=((web_sales.ws_bill_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF1 c_customer_sk->[ws_bill_customer_sk]
13-
--------------------hashAgg[GLOBAL]
14-
----------------------PhysicalDistribute[DistributionSpecHash]
15-
------------------------hashAgg[LOCAL]
16-
--------------------------PhysicalProject
17-
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[ws_sold_date_sk]
18-
------------------------------PhysicalProject
19-
--------------------------------PhysicalOlapScan[web_sales] apply RFs: RF0 RF1
20-
------------------------------PhysicalProject
21-
--------------------------------filter((date_dim.d_month_seq <= 1200) and (date_dim.d_month_seq >= 1189))
22-
----------------------------------PhysicalOlapScan[date_dim]
23-
--------------------PhysicalOlapScan[customer]
24-
----------------PhysicalDistribute[DistributionSpecHash]
25-
------------------hashJoin[INNER_JOIN shuffle] hashCondition=((catalog_sales.cs_bill_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF3 c_customer_sk->[cs_bill_customer_sk]
26-
--------------------hashAgg[GLOBAL]
27-
----------------------PhysicalDistribute[DistributionSpecHash]
28-
------------------------hashAgg[LOCAL]
29-
--------------------------PhysicalProject
30-
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF2 d_date_sk->[cs_sold_date_sk]
31-
------------------------------PhysicalProject
32-
--------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF2 RF3
33-
------------------------------PhysicalProject
34-
--------------------------------filter((date_dim.d_month_seq <= 1200) and (date_dim.d_month_seq >= 1189))
35-
----------------------------------PhysicalOlapScan[date_dim]
36-
--------------------PhysicalOlapScan[customer]
37-
----------------PhysicalDistribute[DistributionSpecHash]
38-
------------------hashJoin[INNER_JOIN shuffle] hashCondition=((store_sales.ss_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF5 c_customer_sk->[ss_customer_sk]
39-
--------------------hashAgg[GLOBAL]
40-
----------------------PhysicalDistribute[DistributionSpecHash]
41-
------------------------hashAgg[LOCAL]
42-
--------------------------PhysicalProject
43-
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF4 d_date_sk->[ss_sold_date_sk]
44-
------------------------------PhysicalProject
45-
--------------------------------PhysicalOlapScan[store_sales] apply RFs: RF4 RF5
46-
------------------------------PhysicalProject
47-
--------------------------------filter((date_dim.d_month_seq <= 1200) and (date_dim.d_month_seq >= 1189))
48-
----------------------------------PhysicalOlapScan[date_dim]
49-
--------------------PhysicalOlapScan[customer]
4+
--PhysicalTopN[GATHER_SORT]
5+
----hashAgg[GLOBAL]
6+
------PhysicalDistribute[DistributionSpecGather]
7+
--------hashAgg[LOCAL]
8+
----------PhysicalProject
9+
------------PhysicalIntersect
10+
--------------PhysicalDistribute[DistributionSpecHash]
11+
----------------hashJoin[INNER_JOIN shuffle] hashCondition=((web_sales.ws_bill_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF1 c_customer_sk->[ws_bill_customer_sk]
12+
------------------hashAgg[GLOBAL]
13+
--------------------PhysicalDistribute[DistributionSpecHash]
14+
----------------------hashAgg[LOCAL]
15+
------------------------PhysicalProject
16+
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[ws_sold_date_sk]
17+
----------------------------PhysicalProject
18+
------------------------------PhysicalOlapScan[web_sales] apply RFs: RF0 RF1
19+
----------------------------PhysicalProject
20+
------------------------------filter((date_dim.d_month_seq <= 1200) and (date_dim.d_month_seq >= 1189))
21+
--------------------------------PhysicalOlapScan[date_dim]
22+
------------------PhysicalOlapScan[customer]
23+
--------------PhysicalDistribute[DistributionSpecHash]
24+
----------------hashJoin[INNER_JOIN shuffle] hashCondition=((catalog_sales.cs_bill_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF3 c_customer_sk->[cs_bill_customer_sk]
25+
------------------hashAgg[GLOBAL]
26+
--------------------PhysicalDistribute[DistributionSpecHash]
27+
----------------------hashAgg[LOCAL]
28+
------------------------PhysicalProject
29+
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF2 d_date_sk->[cs_sold_date_sk]
30+
----------------------------PhysicalProject
31+
------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF2 RF3
32+
----------------------------PhysicalProject
33+
------------------------------filter((date_dim.d_month_seq <= 1200) and (date_dim.d_month_seq >= 1189))
34+
--------------------------------PhysicalOlapScan[date_dim]
35+
------------------PhysicalOlapScan[customer]
36+
--------------PhysicalDistribute[DistributionSpecHash]
37+
----------------hashJoin[INNER_JOIN shuffle] hashCondition=((store_sales.ss_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF5 c_customer_sk->[ss_customer_sk]
38+
------------------hashAgg[GLOBAL]
39+
--------------------PhysicalDistribute[DistributionSpecHash]
40+
----------------------hashAgg[LOCAL]
41+
------------------------PhysicalProject
42+
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF4 d_date_sk->[ss_sold_date_sk]
43+
----------------------------PhysicalProject
44+
------------------------------PhysicalOlapScan[store_sales] apply RFs: RF4 RF5
45+
----------------------------PhysicalProject
46+
------------------------------filter((date_dim.d_month_seq <= 1200) and (date_dim.d_month_seq >= 1189))
47+
--------------------------------PhysicalOlapScan[date_dim]
48+
------------------PhysicalOlapScan[customer]
5049

‎regression-test/data/nereids_tpcds_shape_sf1000_p0/shape/query51.out

+4-4
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@ PhysicalResultSink
1919
--------------------------------PhysicalDistribute[DistributionSpecHash]
2020
----------------------------------hashAgg[LOCAL]
2121
------------------------------------PhysicalProject
22-
--------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF1 d_date_sk->[ss_sold_date_sk]
22+
--------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF1 d_date_sk->[ws_sold_date_sk]
2323
----------------------------------------PhysicalProject
24-
------------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF1
24+
------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF1
2525
----------------------------------------PhysicalProject
2626
------------------------------------------filter((date_dim.d_month_seq <= 1223) and (date_dim.d_month_seq >= 1212))
2727
--------------------------------------------PhysicalOlapScan[date_dim]
@@ -34,9 +34,9 @@ PhysicalResultSink
3434
--------------------------------PhysicalDistribute[DistributionSpecHash]
3535
----------------------------------hashAgg[LOCAL]
3636
------------------------------------PhysicalProject
37-
--------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[ws_sold_date_sk]
37+
--------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[ss_sold_date_sk]
3838
----------------------------------------PhysicalProject
39-
------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF0
39+
------------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF0
4040
----------------------------------------PhysicalProject
4141
------------------------------------------filter((date_dim.d_month_seq <= 1223) and (date_dim.d_month_seq >= 1212))
4242
--------------------------------------------PhysicalOlapScan[date_dim]

0 commit comments

Comments
 (0)