Skip to content

Commit

Permalink
new-shape
Browse files Browse the repository at this point in the history
  • Loading branch information
@englefly
englefly committed Aug 6, 2024
1 parent 030b842 commit 08f5b48
Show file tree
Hide file tree
Showing 54 changed files with 706 additions and 705 deletions.
26 changes: 13 additions & 13 deletions regression-test/data/new_shapes_p0/tpcds_sf100/noStatsRfPrune/query17.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,36 +9,36 @@ PhysicalResultSink
------------PhysicalDistribute[DistributionSpecHash]
--------------hashAgg[LOCAL]
----------------PhysicalProject
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((item.i_item_sk = store_sales.ss_item_sk)) otherCondition=()
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store.s_store_sk = store_sales.ss_store_sk)) otherCondition=()
--------------------PhysicalProject
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store.s_store_sk = store_sales.ss_store_sk)) otherCondition=()
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = d3.d_date_sk)) otherCondition=() build RFs:RF8 d_date_sk->[cs_sold_date_sk]
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = d3.d_date_sk)) otherCondition=() build RFs:RF7 d_date_sk->[cs_sold_date_sk]
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_returns.sr_returned_date_sk = d2.d_date_sk)) otherCondition=() build RFs:RF7 d_date_sk->[sr_returned_date_sk]
----------------------------PhysicalProject
------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_returns.sr_returned_date_sk = d2.d_date_sk)) otherCondition=() build RFs:RF6 d_date_sk->[sr_returned_date_sk]
------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((d1.d_date_sk = store_sales.ss_sold_date_sk)) otherCondition=() build RFs:RF6 d_date_sk->[ss_sold_date_sk]
--------------------------------PhysicalProject
----------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((d1.d_date_sk = store_sales.ss_sold_date_sk)) otherCondition=() build RFs:RF5 d_date_sk->[ss_sold_date_sk]
----------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((item.i_item_sk = store_sales.ss_item_sk)) otherCondition=()
------------------------------------PhysicalProject
--------------------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((store_returns.sr_customer_sk = catalog_sales.cs_bill_customer_sk) and (store_returns.sr_item_sk = catalog_sales.cs_item_sk)) otherCondition=() build RFs:RF3 cs_bill_customer_sk->[sr_customer_sk,ss_customer_sk];RF4 cs_item_sk->[sr_item_sk,ss_item_sk]
----------------------------------------PhysicalProject
------------------------------------------hashJoin[INNER_JOIN colocated] hashCondition=((store_sales.ss_customer_sk = store_returns.sr_customer_sk) and (store_sales.ss_item_sk = store_returns.sr_item_sk) and (store_sales.ss_ticket_number = store_returns.sr_ticket_number)) otherCondition=()
--------------------------------------------PhysicalProject
----------------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF3 RF4 RF5
----------------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF3 RF4 RF6
--------------------------------------------PhysicalProject
----------------------------------------------PhysicalOlapScan[store_returns] apply RFs: RF3 RF4 RF6
----------------------------------------------PhysicalOlapScan[store_returns] apply RFs: RF3 RF4 RF7
----------------------------------------PhysicalProject
------------------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF7
------------------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF8
------------------------------------PhysicalProject
--------------------------------------filter((d1.d_quarter_name = '2001Q1'))
----------------------------------------PhysicalOlapScan[date_dim]
--------------------------------------PhysicalOlapScan[item]
--------------------------------PhysicalProject
----------------------------------filter(d_quarter_name IN ('2001Q1', '2001Q2', '2001Q3'))
----------------------------------filter((d1.d_quarter_name = '2001Q1'))
------------------------------------PhysicalOlapScan[date_dim]
----------------------------PhysicalProject
------------------------------filter(d_quarter_name IN ('2001Q1', '2001Q2', '2001Q3'))
--------------------------------PhysicalOlapScan[date_dim]
------------------------PhysicalProject
--------------------------PhysicalOlapScan[store]
--------------------------filter(d_quarter_name IN ('2001Q1', '2001Q2', '2001Q3'))
----------------------------PhysicalOlapScan[date_dim]
--------------------PhysicalProject
----------------------PhysicalOlapScan[item]
----------------------PhysicalOlapScan[store]

12 changes: 6 additions & 6 deletions regression-test/data/new_shapes_p0/tpcds_sf100/noStatsRfPrune/query18.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,9 @@ PhysicalResultSink
--------------hashAgg[LOCAL]
----------------PhysicalRepeat
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_item_sk = item.i_item_sk)) otherCondition=()
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF5 d_date_sk->[cs_sold_date_sk]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_sold_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF4 d_date_sk->[cs_sold_date_sk]
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_item_sk = item.i_item_sk)) otherCondition=()
--------------------------PhysicalProject
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer.c_current_addr_sk = customer_address.ca_address_sk)) otherCondition=() build RFs:RF3 ca_address_sk->[c_current_addr_sk]
------------------------------PhysicalProject
Expand All @@ -22,7 +22,7 @@ PhysicalResultSink
--------------------------------------PhysicalProject
----------------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((catalog_sales.cs_bill_cdemo_sk = cd1.cd_demo_sk)) otherCondition=() build RFs:RF0 cd_demo_sk->[cs_bill_cdemo_sk]
------------------------------------------PhysicalProject
--------------------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF0 RF1 RF4
--------------------------------------------PhysicalOlapScan[catalog_sales] apply RFs: RF0 RF1 RF5
------------------------------------------PhysicalProject
--------------------------------------------filter((cd1.cd_education_status = 'Advanced Degree') and (cd1.cd_gender = 'F'))
----------------------------------------------PhysicalOlapScan[customer_demographics]
Expand All @@ -35,8 +35,8 @@ PhysicalResultSink
--------------------------------filter(ca_state IN ('GA', 'IN', 'ME', 'NC', 'OK', 'WA', 'WY'))
----------------------------------PhysicalOlapScan[customer_address]
--------------------------PhysicalProject
----------------------------filter((date_dim.d_year = 1998))
------------------------------PhysicalOlapScan[date_dim]
----------------------------PhysicalOlapScan[item]
----------------------PhysicalProject
------------------------PhysicalOlapScan[item]
------------------------filter((date_dim.d_year = 1998))
--------------------------PhysicalOlapScan[date_dim]

22 changes: 11 additions & 11 deletions regression-test/data/new_shapes_p0/tpcds_sf100/noStatsRfPrune/query19.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,25 +11,25 @@ PhysicalResultSink
----------------PhysicalProject
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_store_sk = store.s_store_sk)) otherCondition=(( not (substring(ca_zip, 1, 5) = substring(s_zip, 1, 5))))
--------------------PhysicalProject
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer.c_current_addr_sk = customer_address.ca_address_sk)) otherCondition=()
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_item_sk = item.i_item_sk)) otherCondition=() build RFs:RF3 i_item_sk->[ss_item_sk]
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_customer_sk = customer.c_customer_sk)) otherCondition=()
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((date_dim.d_date_sk = store_sales.ss_sold_date_sk)) otherCondition=() build RFs:RF2 d_date_sk->[ss_sold_date_sk]
----------------------------PhysicalProject
------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_item_sk = item.i_item_sk)) otherCondition=() build RFs:RF1 i_item_sk->[ss_item_sk]
------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer.c_current_addr_sk = customer_address.ca_address_sk)) otherCondition=()
--------------------------------PhysicalProject
----------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((date_dim.d_date_sk = store_sales.ss_sold_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[ss_sold_date_sk]
----------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_customer_sk = customer.c_customer_sk)) otherCondition=()
------------------------------------PhysicalProject
--------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF0 RF1
--------------------------------------PhysicalOlapScan[store_sales] apply RFs: RF2 RF3
------------------------------------PhysicalProject
--------------------------------------filter((date_dim.d_moy = 12) and (date_dim.d_year = 1999))
----------------------------------------PhysicalOlapScan[date_dim]
--------------------------------------PhysicalOlapScan[customer]
--------------------------------PhysicalProject
----------------------------------filter((item.i_manager_id = 2))
------------------------------------PhysicalOlapScan[item]
----------------------------------PhysicalOlapScan[customer_address]
----------------------------PhysicalProject
------------------------------PhysicalOlapScan[customer]
------------------------------filter((date_dim.d_moy = 12) and (date_dim.d_year = 1999))
--------------------------------PhysicalOlapScan[date_dim]
------------------------PhysicalProject
--------------------------PhysicalOlapScan[customer_address]
--------------------------filter((item.i_manager_id = 2))
----------------------------PhysicalOlapScan[item]
--------------------PhysicalProject
----------------------PhysicalOlapScan[store]

12 changes: 6 additions & 6 deletions regression-test/data/new_shapes_p0/tpcds_sf100/noStatsRfPrune/query22.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,14 @@ PhysicalResultSink
--------------hashAgg[LOCAL]
----------------PhysicalRepeat
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((inventory.inv_item_sk = item.i_item_sk)) otherCondition=()
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((inventory.inv_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF1 d_date_sk->[inv_date_sk]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((inventory.inv_date_sk = date_dim.d_date_sk)) otherCondition=() build RFs:RF0 d_date_sk->[inv_date_sk]
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((inventory.inv_item_sk = item.i_item_sk)) otherCondition=()
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[inventory] apply RFs: RF0
----------------------------PhysicalOlapScan[inventory] apply RFs: RF1
--------------------------PhysicalProject
----------------------------filter((date_dim.d_month_seq <= 1199) and (date_dim.d_month_seq >= 1188))
------------------------------PhysicalOlapScan[date_dim]
----------------------------PhysicalOlapScan[item]
----------------------PhysicalProject
------------------------PhysicalOlapScan[item]
------------------------filter((date_dim.d_month_seq <= 1199) and (date_dim.d_month_seq >= 1188))
--------------------------PhysicalOlapScan[date_dim]

12 changes: 6 additions & 6 deletions regression-test/data/new_shapes_p0/tpcds_sf100/noStatsRfPrune/query23.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,16 +8,16 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_item_sk = item.i_item_sk)) otherCondition=()
----------------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]
------------------PhysicalProject
--------------------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]
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_item_sk = item.i_item_sk)) otherCondition=()
----------------------PhysicalProject
------------------------PhysicalOlapScan[store_sales] apply RFs: RF0
------------------------PhysicalOlapScan[store_sales] apply RFs: RF1
----------------------PhysicalProject
------------------------filter(d_year IN (2000, 2001, 2002, 2003))
--------------------------PhysicalOlapScan[date_dim]
------------------------PhysicalOlapScan[item]
------------------PhysicalProject
--------------------PhysicalOlapScan[item]
--------------------filter(d_year IN (2000, 2001, 2002, 2003))
----------------------PhysicalOlapScan[date_dim]
--PhysicalCteAnchor ( cteId=CTEId#2 )
----PhysicalCteProducer ( cteId=CTEId#2 )
------PhysicalProject
Expand Down
20 changes: 10 additions & 10 deletions regression-test/data/new_shapes_p0/tpcds_sf100/noStatsRfPrune/query24.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,28 +7,28 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------PhysicalDistribute[DistributionSpecHash]
----------hashAgg[LOCAL]
------------PhysicalProject
--------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer.c_current_addr_sk = customer_address.ca_address_sk) and (store.s_zip = customer_address.ca_zip)) otherCondition=(( not (c_birth_country = upper(ca_country))))
--------------hashJoin[INNER_JOIN broadcast] hashCondition=((store.s_zip = customer_address.ca_zip) and (store_sales.ss_store_sk = store.s_store_sk)) otherCondition=() build RFs:RF5 s_zip->[ca_zip];RF6 s_store_sk->[ss_store_sk]
----------------PhysicalProject
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_customer_sk = customer.c_customer_sk)) otherCondition=()
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((customer.c_current_addr_sk = customer_address.ca_address_sk)) otherCondition=(( not (c_birth_country = upper(ca_country)))) build RFs:RF4 ca_address_sk->[c_current_addr_sk]
--------------------PhysicalProject
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_item_sk = item.i_item_sk)) otherCondition=()
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_customer_sk = customer.c_customer_sk)) otherCondition=() build RFs:RF3 c_customer_sk->[ss_customer_sk]
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_store_sk = store.s_store_sk)) otherCondition=() build RFs:RF2 s_store_sk->[ss_store_sk]
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((store_sales.ss_item_sk = item.i_item_sk)) otherCondition=()
----------------------------PhysicalProject
------------------------------hashJoin[INNER_JOIN colocated] hashCondition=((store_sales.ss_item_sk = store_returns.sr_item_sk) and (store_sales.ss_ticket_number = store_returns.sr_ticket_number)) otherCondition=()
--------------------------------PhysicalProject
----------------------------------PhysicalOlapScan[store_sales] apply RFs: RF2
----------------------------------PhysicalOlapScan[store_sales] apply RFs: RF3 RF6
--------------------------------PhysicalProject
----------------------------------PhysicalOlapScan[store_returns]
----------------------------PhysicalProject
------------------------------filter((store.s_market_id = 8))
--------------------------------PhysicalOlapScan[store]
------------------------------PhysicalOlapScan[item]
------------------------PhysicalProject
--------------------------PhysicalOlapScan[item]
--------------------------PhysicalOlapScan[customer] apply RFs: RF4
--------------------PhysicalProject
----------------------PhysicalOlapScan[customer]
----------------------PhysicalOlapScan[customer_address] apply RFs: RF5
----------------PhysicalProject
------------------PhysicalOlapScan[customer_address]
------------------filter((store.s_market_id = 8))
--------------------PhysicalOlapScan[store]
--PhysicalResultSink
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute[DistributionSpecGather]
Expand Down
Loading

0 comments on commit 08f5b48

Please sign in to comment.