Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
@englefly
englefly committed Sep 29, 2024
1 parent 1bae2b6 commit c3538b2
Show file tree
Hide file tree
Showing 199 changed files with 968 additions and 973 deletions.
8 changes: 4 additions & 4 deletions regression-test/data/nereids_tpcds_shape_sf10t_orc/shape/query1.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,10 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------PhysicalProject
--------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_returns.sr_returned_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[sr_returned_date_sk]
----------------PhysicalProject
------------------PhysicalFileScan[store_returns] apply RFs: RF0
------------------PhysicalOlapScan[store_returns] apply RFs: RF0
----------------PhysicalProject
------------------filter((date_dim.d_year = 2000))
--------------------PhysicalFileScan[date_dim]
--------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute[DistributionSpecGather]
Expand All @@ -25,10 +25,10 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------------------hashJoin[INNER_JOIN shuffle] hashCondition=((ctr1.ctr_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF1 c_customer_sk->[ctr_customer_sk]
----------------------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF1 RF2 RF3
----------------------PhysicalProject
------------------------PhysicalFileScan[customer]
------------------------PhysicalOlapScan[customer]
------------------PhysicalProject
--------------------filter((store.s_state = 'NM'))
----------------------PhysicalFileScan[store] apply RFs: RF3
----------------------PhysicalOlapScan[store] apply RFs: RF3
--------------hashAgg[GLOBAL]
----------------PhysicalDistribute[DistributionSpecHash]
------------------hashAgg[LOCAL]
Expand Down
42 changes: 21 additions & 21 deletions regression-test/data/nereids_tpcds_shape_sf10t_orc/shape/query10.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,38 +10,38 @@ PhysicalResultSink
--------------hashAgg[LOCAL]
----------------PhysicalProject
------------------filter((ifnull($c$1, FALSE) OR ifnull($c$2, FALSE)))
--------------------hashJoin[LEFT_SEMI_JOIN shuffle] hashCondition=((c.c_customer_sk = catalog_sales.cs_ship_customer_sk)) otherCondition=()
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer_demographics.cd_demo_sk = c.c_current_cdemo_sk)) otherCondition=() build RFs:RF5 cd_demo_sk->[c_current_cdemo_sk]
--------------------------PhysicalProject
----------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((c.c_current_addr_sk = ca.ca_address_sk)) otherCondition=() build RFs:RF4 ca_address_sk->[c_current_addr_sk]
------------------------------hashJoin[LEFT_SEMI_JOIN bucketShuffle] hashCondition=((c.c_customer_sk = web_sales.ws_bill_customer_sk)) otherCondition=()
--------------------hashJoin[LEFT_SEMI_JOIN bucketShuffle] hashCondition=((c.c_customer_sk = catalog_sales.cs_ship_customer_sk)) otherCondition=()
----------------------hashJoin[LEFT_SEMI_JOIN shuffle] hashCondition=((c.c_customer_sk = web_sales.ws_bill_customer_sk)) otherCondition=()
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer_demographics.cd_demo_sk = c.c_current_cdemo_sk)) otherCondition=() build RFs:RF5 cd_demo_sk->[c_current_cdemo_sk]
----------------------------PhysicalProject
------------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((c.c_current_addr_sk = ca.ca_address_sk)) otherCondition=() build RFs:RF4 ca_address_sk->[c_current_addr_sk]
--------------------------------hashJoin[RIGHT_SEMI_JOIN shuffle] hashCondition=((c.c_customer_sk = store_sales.ss_customer_sk)) otherCondition=() build RFs:RF3 c_customer_sk->[ss_customer_sk]
----------------------------------PhysicalProject
------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF2 d_date_sk->[ss_sold_date_sk]
--------------------------------------PhysicalProject
----------------------------------------PhysicalFileScan[store_sales] apply RFs: RF2 RF3
----------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF2 RF3
--------------------------------------PhysicalProject
----------------------------------------filter((date_dim.d_moy <= 6) and (date_dim.d_moy >= 3) and (date_dim.d_year = 2000))
------------------------------------------PhysicalFileScan[date_dim]
------------------------------------------PhysicalOlapScan[date_dim]
----------------------------------PhysicalProject
------------------------------------PhysicalFileScan[customer] apply RFs: RF4 RF5
------------------------------------PhysicalOlapScan[customer] apply RFs: RF4 RF5
--------------------------------PhysicalProject
----------------------------------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]
------------------------------------PhysicalProject
--------------------------------------PhysicalFileScan[web_sales] apply RFs: RF1
------------------------------------PhysicalProject
--------------------------------------filter((date_dim.d_moy <= 6) and (date_dim.d_moy >= 3) and (date_dim.d_year = 2000))
----------------------------------------PhysicalFileScan[date_dim]
------------------------------PhysicalProject
--------------------------------filter(ca_county IN ('Bonneville County', 'Boone County', 'Brown County', 'Fillmore County', 'McPherson County'))
----------------------------------PhysicalFileScan[customer_address]
--------------------------PhysicalFileScan[customer_demographics]
----------------------------------filter(ca_county IN ('Bonneville County', 'Boone County', 'Brown County', 'Fillmore County', 'McPherson County'))
------------------------------------PhysicalOlapScan[customer_address]
----------------------------PhysicalOlapScan[customer_demographics]
------------------------PhysicalProject
--------------------------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]
----------------------------PhysicalProject
------------------------------PhysicalOlapScan[web_sales] apply RFs: RF1
----------------------------PhysicalProject
------------------------------filter((date_dim.d_moy <= 6) and (date_dim.d_moy >= 3) and (date_dim.d_year = 2000))
--------------------------------PhysicalOlapScan[date_dim]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[cs_sold_date_sk]
--------------------------PhysicalProject
----------------------------PhysicalFileScan[catalog_sales] apply RFs: RF0
----------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF0
--------------------------PhysicalProject
----------------------------filter((date_dim.d_moy <= 6) and (date_dim.d_moy >= 3) and (date_dim.d_year = 2000))
------------------------------PhysicalFileScan[date_dim]
------------------------------PhysicalOlapScan[date_dim]

12 changes: 6 additions & 6 deletions regression-test/data/nereids_tpcds_shape_sf10t_orc/shape/query11.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,12 +12,12 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN shuffle] hashCondition=((customer.c_customer_sk = store_sales.ss_customer_sk)) otherCondition=() build RFs:RF0 c_customer_sk->[ss_customer_sk]
----------------------PhysicalProject
------------------------PhysicalFileScan[store_sales] apply RFs: RF0 RF1
------------------------PhysicalOlapScan[store_sales] apply RFs: RF0 RF1
----------------------PhysicalProject
------------------------PhysicalFileScan[customer]
------------------------PhysicalOlapScan[customer]
------------------PhysicalProject
--------------------filter(d_year IN (1999, 2000))
----------------------PhysicalFileScan[date_dim]
----------------------PhysicalOlapScan[date_dim]
------PhysicalProject
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
Expand All @@ -27,12 +27,12 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN shuffle] hashCondition=((customer.c_customer_sk = web_sales.ws_bill_customer_sk)) otherCondition=() build RFs:RF2 c_customer_sk->[ws_bill_customer_sk]
----------------------PhysicalProject
------------------------PhysicalFileScan[web_sales] apply RFs: RF2 RF3
------------------------PhysicalOlapScan[web_sales] apply RFs: RF2 RF3
----------------------PhysicalProject
------------------------PhysicalFileScan[customer]
------------------------PhysicalOlapScan[customer]
------------------PhysicalProject
--------------------filter(d_year IN (1999, 2000))
----------------------PhysicalFileScan[date_dim]
----------------------PhysicalOlapScan[date_dim]
--PhysicalResultSink
----PhysicalTopN[MERGE_SORT]
------PhysicalDistribute[DistributionSpecGather]
Expand Down
6 changes: 3 additions & 3 deletions regression-test/data/nereids_tpcds_shape_sf10t_orc/shape/query12.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@ PhysicalResultSink
--------------------------PhysicalProject
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((web_sales.ws_item_sk = item.i_item_sk)) otherCondition=() build RFs:RF0 i_item_sk->[ws_item_sk]
------------------------------PhysicalProject
--------------------------------PhysicalFileScan[web_sales] apply RFs: RF0 RF1
--------------------------------PhysicalOlapScan[web_sales] apply RFs: RF0 RF1
------------------------------PhysicalProject
--------------------------------filter(i_category IN ('Books', 'Electronics', 'Women'))
----------------------------------PhysicalFileScan[item]
----------------------------------PhysicalOlapScan[item]
--------------------------PhysicalProject
----------------------------filter((date_dim.d_date <= '1998-02-05') and (date_dim.d_date >= '1998-01-06'))
------------------------------PhysicalFileScan[date_dim]
------------------------------PhysicalOlapScan[date_dim]

12 changes: 6 additions & 6 deletions regression-test/data/nereids_tpcds_shape_sf10t_orc/shape/query13.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,19 +16,19 @@ PhysicalResultSink
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store.s_store_sk = store_sales.ss_store_sk)) otherCondition=() build RFs:RF0 s_store_sk->[ss_store_sk]
----------------------------PhysicalProject
------------------------------filter((store_sales.ss_net_profit <= 300.00) and (store_sales.ss_net_profit >= 50.00) and (store_sales.ss_sales_price <= 200.00) and (store_sales.ss_sales_price >= 50.00))
--------------------------------PhysicalFileScan[store_sales] apply RFs: RF0 RF1 RF2 RF3 RF4
--------------------------------PhysicalOlapScan[store_sales] apply RFs: RF0 RF1 RF2 RF3 RF4
----------------------------PhysicalProject
------------------------------PhysicalFileScan[store]
------------------------------PhysicalOlapScan[store]
------------------------PhysicalProject
--------------------------filter(((((customer_demographics.cd_marital_status = 'U') AND (customer_demographics.cd_education_status = 'Secondary')) OR ((customer_demographics.cd_marital_status = 'W') AND (customer_demographics.cd_education_status = 'College'))) OR ((customer_demographics.cd_marital_status = 'D') AND (customer_demographics.cd_education_status = 'Primary'))) and cd_education_status IN ('College', 'Primary', 'Secondary') and cd_marital_status IN ('D', 'U', 'W'))
----------------------------PhysicalFileScan[customer_demographics]
----------------------------PhysicalOlapScan[customer_demographics]
--------------------PhysicalProject
----------------------filter(hd_dep_count IN (1, 3))
------------------------PhysicalFileScan[household_demographics]
------------------------PhysicalOlapScan[household_demographics]
----------------PhysicalProject
------------------filter((customer_address.ca_country = 'United States') and ca_state IN ('FL', 'GA', 'MI', 'MT', 'NC', 'OH', 'OK', 'TX', 'WA'))
--------------------PhysicalFileScan[customer_address]
--------------------PhysicalOlapScan[customer_address]
------------PhysicalProject
--------------filter((date_dim.d_year = 2001))
----------------PhysicalFileScan[date_dim]
----------------PhysicalOlapScan[date_dim]

Loading

0 comments on commit c3538b2

Please sign in to comment.