Skip to content

Commit 3fcb7b1

Browse files
morrySnowmorrySnow
committed
[dnm](draft) test right dsg
1 parent 5df1162 commit 3fcb7b1

File tree

39 files changed

+138
-166
lines changed

39 files changed

+138
-166
lines changed

‎fe/fe-core/src/main/java/org/apache/doris/nereids/properties/ChildrenPropertiesRegulator.java‎

Lines changed: 62 additions & 94 deletions
Large diffs are not rendered by default.

‎regression-test/data/shape_check/tpcds_sf100/noStatsRfPrune/query49.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ PhysicalResultSink
3030
------------------------------------------------------PhysicalProject
3131
--------------------------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((ws.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF2 d_date_sk->[ws_sold_date_sk]
3232
----------------------------------------------------------PhysicalProject
33-
------------------------------------------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((ws.ws_item_sk = wr.wr_item_sk) and (ws.ws_order_number = wr.wr_order_number)) otherCondition=() build RFs:RF0 wr_order_number->[ws_order_number];RF1 wr_item_sk->[ws_item_sk]
33+
------------------------------------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((ws.ws_item_sk = wr.wr_item_sk) and (ws.ws_order_number = wr.wr_order_number)) otherCondition=() build RFs:RF0 wr_order_number->[ws_order_number];RF1 wr_item_sk->[ws_item_sk]
3434
--------------------------------------------------------------PhysicalProject
3535
----------------------------------------------------------------filter((ws.ws_net_paid > 0.00) and (ws.ws_net_profit > 1.00) and (ws.ws_quantity > 0))
3636
------------------------------------------------------------------PhysicalOlapScan[web_sales(ws)] apply RFs: RF0 RF1 RF2

‎regression-test/data/shape_check/tpcds_sf100/noStatsRfPrune/query5.out‎

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,13 @@ PhysicalResultSink
6262
--------------------------------------PhysicalDistribute[DistributionSpecExecutionAny]
6363
----------------------------------------PhysicalProject
6464
------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF6
65-
--------------------------------------PhysicalProject
66-
----------------------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((web_returns.wr_item_sk = web_sales.ws_item_sk) and (web_returns.wr_order_number = web_sales.ws_order_number)) otherCondition=() build RFs:RF4 wr_item_sk->[ws_item_sk];RF5 wr_order_number->[ws_order_number]
67-
------------------------------------------PhysicalProject
68-
--------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF4 RF5
69-
------------------------------------------PhysicalProject
70-
--------------------------------------------PhysicalOlapScan[web_returns] apply RFs: RF6
65+
--------------------------------------PhysicalDistribute[DistributionSpecExecutionAny]
66+
----------------------------------------PhysicalProject
67+
------------------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((web_returns.wr_item_sk = web_sales.ws_item_sk) and (web_returns.wr_order_number = web_sales.ws_order_number)) otherCondition=() build RFs:RF4 wr_item_sk->[ws_item_sk];RF5 wr_order_number->[ws_order_number]
68+
--------------------------------------------PhysicalProject
69+
----------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF4 RF5
70+
--------------------------------------------PhysicalProject
71+
----------------------------------------------PhysicalOlapScan[web_returns] apply RFs: RF6
7172
------------------------------------PhysicalProject
7273
--------------------------------------filter((date_dim.d_date <= '2000-09-02') and (date_dim.d_date >= '2000-08-19'))
7374
----------------------------------------PhysicalOlapScan[date_dim]

‎regression-test/data/shape_check/tpcds_sf100/noStatsRfPrune/query75.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
5454
--------------------------PhysicalProject
5555
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((item.i_item_sk = web_sales.ws_item_sk)) otherCondition=() build RFs:RF4 i_item_sk->[ws_item_sk]
5656
------------------------------PhysicalProject
57-
--------------------------------hashJoin[LEFT_OUTER_JOIN shuffle] hashCondition=((web_sales.ws_item_sk = web_returns.wr_item_sk) and (web_sales.ws_order_number = web_returns.wr_order_number)) otherCondition=()
57+
--------------------------------hashJoin[LEFT_OUTER_JOIN bucketShuffle] hashCondition=((web_sales.ws_item_sk = web_returns.wr_item_sk) and (web_sales.ws_order_number = web_returns.wr_order_number)) otherCondition=()
5858
----------------------------------PhysicalProject
5959
------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF4 RF5
6060
----------------------------------PhysicalProject

‎regression-test/data/shape_check/tpcds_sf100/noStatsRfPrune/query78.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ PhysicalResultSink
3131
--------------------------PhysicalProject
3232
----------------------------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]
3333
------------------------------PhysicalProject
34-
--------------------------------hashJoin[LEFT_ANTI_JOIN shuffle] hashCondition=((web_returns.wr_order_number = web_sales.ws_order_number) and (web_sales.ws_item_sk = web_returns.wr_item_sk)) otherCondition=()
34+
--------------------------------hashJoin[LEFT_ANTI_JOIN bucketShuffle] hashCondition=((web_returns.wr_order_number = web_sales.ws_order_number) and (web_sales.ws_item_sk = web_returns.wr_item_sk)) otherCondition=()
3535
----------------------------------PhysicalProject
3636
------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF1
3737
----------------------------------PhysicalProject

‎regression-test/data/shape_check/tpcds_sf100/noStatsRfPrune/query80.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ PhysicalResultSink
8181
----------------------------------------PhysicalProject
8282
------------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF8 d_date_sk->[ws_sold_date_sk]
8383
--------------------------------------------PhysicalProject
84-
----------------------------------------------hashJoin[LEFT_OUTER_JOIN shuffle] hashCondition=((web_sales.ws_item_sk = web_returns.wr_item_sk) and (web_sales.ws_order_number = web_returns.wr_order_number)) otherCondition=()
84+
----------------------------------------------hashJoin[LEFT_OUTER_JOIN bucketShuffle] hashCondition=((web_sales.ws_item_sk = web_returns.wr_item_sk) and (web_sales.ws_order_number = web_returns.wr_order_number)) otherCondition=()
8585
------------------------------------------------PhysicalProject
8686
--------------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF8 RF10 RF11
8787
------------------------------------------------PhysicalProject

‎regression-test/data/shape_check/tpcds_sf100/no_stats_shape/query49.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ PhysicalResultSink
3030
------------------------------------------------------PhysicalProject
3131
--------------------------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((ws.ws_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF2 d_date_sk->[ws_sold_date_sk]
3232
----------------------------------------------------------PhysicalProject
33-
------------------------------------------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((ws.ws_item_sk = wr.wr_item_sk) and (ws.ws_order_number = wr.wr_order_number)) otherCondition=() build RFs:RF0 wr_order_number->[ws_order_number];RF1 wr_item_sk->[ws_item_sk]
33+
------------------------------------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((ws.ws_item_sk = wr.wr_item_sk) and (ws.ws_order_number = wr.wr_order_number)) otherCondition=() build RFs:RF0 wr_order_number->[ws_order_number];RF1 wr_item_sk->[ws_item_sk]
3434
--------------------------------------------------------------PhysicalProject
3535
----------------------------------------------------------------filter((ws.ws_net_paid > 0.00) and (ws.ws_net_profit > 1.00) and (ws.ws_quantity > 0))
3636
------------------------------------------------------------------PhysicalOlapScan[web_sales(ws)] apply RFs: RF0 RF1 RF2

‎regression-test/data/shape_check/tpcds_sf100/no_stats_shape/query5.out‎

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,13 @@ PhysicalResultSink
6262
--------------------------------------PhysicalDistribute[DistributionSpecExecutionAny]
6363
----------------------------------------PhysicalProject
6464
------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF6 RF7
65-
--------------------------------------PhysicalProject
66-
----------------------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((web_returns.wr_item_sk = web_sales.ws_item_sk) and (web_returns.wr_order_number = web_sales.ws_order_number)) otherCondition=() build RFs:RF4 wr_item_sk->[ws_item_sk];RF5 wr_order_number->[ws_order_number]
67-
------------------------------------------PhysicalProject
68-
--------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF4 RF5 RF7
69-
------------------------------------------PhysicalProject
70-
--------------------------------------------PhysicalOlapScan[web_returns] apply RFs: RF6
65+
--------------------------------------PhysicalDistribute[DistributionSpecExecutionAny]
66+
----------------------------------------PhysicalProject
67+
------------------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((web_returns.wr_item_sk = web_sales.ws_item_sk) and (web_returns.wr_order_number = web_sales.ws_order_number)) otherCondition=() build RFs:RF4 wr_item_sk->[ws_item_sk];RF5 wr_order_number->[ws_order_number]
68+
--------------------------------------------PhysicalProject
69+
----------------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF4 RF5 RF7
70+
--------------------------------------------PhysicalProject
71+
----------------------------------------------PhysicalOlapScan[web_returns] apply RFs: RF6
7172
------------------------------------PhysicalProject
7273
--------------------------------------filter((date_dim.d_date <= '2000-09-02') and (date_dim.d_date >= '2000-08-19'))
7374
----------------------------------------PhysicalOlapScan[date_dim]

‎regression-test/data/shape_check/tpcds_sf100/no_stats_shape/query75.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
5454
--------------------------PhysicalProject
5555
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((item.i_item_sk = web_sales.ws_item_sk)) otherCondition=() build RFs:RF4 i_item_sk->[ws_item_sk]
5656
------------------------------PhysicalProject
57-
--------------------------------hashJoin[LEFT_OUTER_JOIN shuffle] hashCondition=((web_sales.ws_item_sk = web_returns.wr_item_sk) and (web_sales.ws_order_number = web_returns.wr_order_number)) otherCondition=()
57+
--------------------------------hashJoin[LEFT_OUTER_JOIN bucketShuffle] hashCondition=((web_sales.ws_item_sk = web_returns.wr_item_sk) and (web_sales.ws_order_number = web_returns.wr_order_number)) otherCondition=()
5858
----------------------------------PhysicalProject
5959
------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF4 RF5
6060
----------------------------------PhysicalProject

‎regression-test/data/shape_check/tpcds_sf100/no_stats_shape/query78.out‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ PhysicalResultSink
3131
--------------------------PhysicalProject
3232
----------------------------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]
3333
------------------------------PhysicalProject
34-
--------------------------------hashJoin[LEFT_ANTI_JOIN shuffle] hashCondition=((web_returns.wr_order_number = web_sales.ws_order_number) and (web_sales.ws_item_sk = web_returns.wr_item_sk)) otherCondition=()
34+
--------------------------------hashJoin[LEFT_ANTI_JOIN bucketShuffle] hashCondition=((web_returns.wr_order_number = web_sales.ws_order_number) and (web_sales.ws_item_sk = web_returns.wr_item_sk)) otherCondition=()
3535
----------------------------------PhysicalProject
3636
------------------------------------PhysicalOlapScan[web_sales] apply RFs: RF1
3737
----------------------------------PhysicalProject

0 commit comments

Comments
 (0)