Skip to content

Commit

Permalink
shape
Browse files Browse the repository at this point in the history
  • Loading branch information
@englefly
englefly committed Dec 25, 2024
1 parent 8ae7800 commit 8748b2e
Show file tree
Hide file tree
Showing 165 changed files with 4,838 additions and 4,602 deletions.
36 changes: 19 additions & 17 deletions regression-test/data/shape_check/ssb_sf100/shape/q2.1.out
View file
Original file line number Diff line number Diff line change
@@ -1,26 +1,28 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute[DistributionSpecGather]
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
--PhysicalProject
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute[DistributionSpecGather]
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashAgg[GLOBAL]
--------------PhysicalDistribute[DistributionSpecHash]
----------------hashAgg[LOCAL]
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF1 s_suppkey->[lo_suppkey]
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_partkey = part.p_partkey)) otherCondition=() build RFs:RF0 p_partkey->[lo_partkey]
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF1 s_suppkey->[lo_suppkey]
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_partkey = part.p_partkey)) otherCondition=() build RFs:RF0 p_partkey->[lo_partkey]
------------------------------PhysicalProject
--------------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
------------------------------PhysicalProject
--------------------------------filter((part.p_category = 'MFGR#12'))
----------------------------------PhysicalOlapScan[part]
--------------------------PhysicalProject
----------------------------filter((part.p_category = 'MFGR#12'))
------------------------------PhysicalOlapScan[part]
----------------------------filter((supplier.s_region = 'AMERICA'))
------------------------------PhysicalOlapScan[supplier]
----------------------PhysicalProject
------------------------filter((supplier.s_region = 'AMERICA'))
--------------------------PhysicalOlapScan[supplier]
------------------PhysicalProject
--------------------PhysicalOlapScan[dates]
------------------------PhysicalOlapScan[dates]

36 changes: 19 additions & 17 deletions regression-test/data/shape_check/ssb_sf100/shape/q2.2.out
View file
Original file line number Diff line number Diff line change
@@ -1,26 +1,28 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute[DistributionSpecGather]
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
--PhysicalProject
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute[DistributionSpecGather]
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashAgg[GLOBAL]
--------------PhysicalDistribute[DistributionSpecHash]
----------------hashAgg[LOCAL]
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_partkey = part.p_partkey)) otherCondition=() build RFs:RF1 p_partkey->[lo_partkey]
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_partkey = part.p_partkey)) otherCondition=() build RFs:RF1 p_partkey->[lo_partkey]
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
------------------------------PhysicalProject
--------------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
------------------------------PhysicalProject
--------------------------------filter((supplier.s_region = 'ASIA'))
----------------------------------PhysicalOlapScan[supplier]
--------------------------PhysicalProject
----------------------------filter((supplier.s_region = 'ASIA'))
------------------------------PhysicalOlapScan[supplier]
----------------------------filter((part.p_brand <= 'MFGR#2228') and (part.p_brand >= 'MFGR#2221'))
------------------------------PhysicalOlapScan[part]
----------------------PhysicalProject
------------------------filter((part.p_brand <= 'MFGR#2228') and (part.p_brand >= 'MFGR#2221'))
--------------------------PhysicalOlapScan[part]
------------------PhysicalProject
--------------------PhysicalOlapScan[dates]
------------------------PhysicalOlapScan[dates]

36 changes: 19 additions & 17 deletions regression-test/data/shape_check/ssb_sf100/shape/q2.3.out
View file
Original file line number Diff line number Diff line change
@@ -1,26 +1,28 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
PhysicalResultSink
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute[DistributionSpecGather]
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
--PhysicalProject
----PhysicalQuickSort[MERGE_SORT]
------PhysicalDistribute[DistributionSpecGather]
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalProject
------------hashAgg[GLOBAL]
--------------PhysicalDistribute[DistributionSpecHash]
----------------hashAgg[LOCAL]
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF1 s_suppkey->[lo_suppkey]
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_partkey = part.p_partkey)) otherCondition=() build RFs:RF0 p_partkey->[lo_partkey]
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF1 s_suppkey->[lo_suppkey]
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
----------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_partkey = part.p_partkey)) otherCondition=() build RFs:RF0 p_partkey->[lo_partkey]
------------------------------PhysicalProject
--------------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
------------------------------PhysicalProject
--------------------------------filter((part.p_brand = 'MFGR#2239'))
----------------------------------PhysicalOlapScan[part]
--------------------------PhysicalProject
----------------------------filter((part.p_brand = 'MFGR#2239'))
------------------------------PhysicalOlapScan[part]
----------------------------filter((supplier.s_region = 'EUROPE'))
------------------------------PhysicalOlapScan[supplier]
----------------------PhysicalProject
------------------------filter((supplier.s_region = 'EUROPE'))
--------------------------PhysicalOlapScan[supplier]
------------------PhysicalProject
--------------------PhysicalOlapScan[dates]
------------------------PhysicalOlapScan[dates]

41 changes: 21 additions & 20 deletions regression-test/data/shape_check/ssb_sf100/shape/q3.2.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,24 +4,25 @@ PhysicalResultSink
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute[DistributionSpecGather]
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_custkey = customer.c_custkey)) otherCondition=() build RFs:RF1 c_custkey->[lo_custkey]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
--------------------------PhysicalProject
----------------------------filter((supplier.s_nation = 'UNITED STATES'))
------------------------------PhysicalOlapScan[supplier]
----------------------PhysicalProject
------------------------filter((customer.c_nation = 'UNITED STATES'))
--------------------------PhysicalOlapScan[customer]
------------------PhysicalProject
--------------------filter((dates.d_year <= 1997) and (dates.d_year >= 1992))
----------------------PhysicalOlapScan[dates]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute[DistributionSpecHash]
--------------hashAgg[LOCAL]
----------------PhysicalProject
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
--------------------PhysicalProject
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF1 s_suppkey->[lo_suppkey]
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_custkey = customer.c_custkey)) otherCondition=() build RFs:RF0 c_custkey->[lo_custkey]
----------------------------PhysicalProject
------------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
----------------------------PhysicalProject
------------------------------filter((customer.c_nation = 'UNITED STATES'))
--------------------------------PhysicalOlapScan[customer]
------------------------PhysicalProject
--------------------------filter((supplier.s_nation = 'UNITED STATES'))
----------------------------PhysicalOlapScan[supplier]
--------------------PhysicalProject
----------------------filter((dates.d_year <= 1997) and (dates.d_year >= 1992))
------------------------PhysicalOlapScan[dates]

41 changes: 21 additions & 20 deletions regression-test/data/shape_check/ssb_sf100/shape/q3.3.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,24 +4,25 @@ PhysicalResultSink
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute[DistributionSpecGather]
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_custkey = customer.c_custkey)) otherCondition=() build RFs:RF1 c_custkey->[lo_custkey]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
--------------------------PhysicalProject
----------------------------filter(s_city IN ('UNITED KI1', 'UNITED KI5'))
------------------------------PhysicalOlapScan[supplier]
----------------------PhysicalProject
------------------------filter(c_city IN ('UNITED KI1', 'UNITED KI5'))
--------------------------PhysicalOlapScan[customer]
------------------PhysicalProject
--------------------filter((dates.d_year <= 1997) and (dates.d_year >= 1992))
----------------------PhysicalOlapScan[dates]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute[DistributionSpecHash]
--------------hashAgg[LOCAL]
----------------PhysicalProject
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
--------------------PhysicalProject
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_custkey = customer.c_custkey)) otherCondition=() build RFs:RF1 c_custkey->[lo_custkey]
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
----------------------------PhysicalProject
------------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
----------------------------PhysicalProject
------------------------------filter(s_city IN ('UNITED KI1', 'UNITED KI5'))
--------------------------------PhysicalOlapScan[supplier]
------------------------PhysicalProject
--------------------------filter(c_city IN ('UNITED KI1', 'UNITED KI5'))
----------------------------PhysicalOlapScan[customer]
--------------------PhysicalProject
----------------------filter((dates.d_year <= 1997) and (dates.d_year >= 1992))
------------------------PhysicalOlapScan[dates]

41 changes: 21 additions & 20 deletions regression-test/data/shape_check/ssb_sf100/shape/q3.4.out
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,24 +4,25 @@ PhysicalResultSink
--PhysicalQuickSort[MERGE_SORT]
----PhysicalDistribute[DistributionSpecGather]
------PhysicalQuickSort[LOCAL_SORT]
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------hashAgg[LOCAL]
--------------PhysicalProject
----------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
------------------PhysicalProject
--------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_custkey = customer.c_custkey)) otherCondition=() build RFs:RF1 c_custkey->[lo_custkey]
----------------------PhysicalProject
------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
--------------------------PhysicalProject
----------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
--------------------------PhysicalProject
----------------------------filter(s_city IN ('UNITED KI1', 'UNITED KI5'))
------------------------------PhysicalOlapScan[supplier]
----------------------PhysicalProject
------------------------filter(c_city IN ('UNITED KI1', 'UNITED KI5'))
--------------------------PhysicalOlapScan[customer]
------------------PhysicalProject
--------------------filter((dates.d_yearmonth = 'Dec1997'))
----------------------PhysicalOlapScan[dates]
--------PhysicalProject
----------hashAgg[GLOBAL]
------------PhysicalDistribute[DistributionSpecHash]
--------------hashAgg[LOCAL]
----------------PhysicalProject
------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_orderdate = dates.d_datekey)) otherCondition=() build RFs:RF2 d_datekey->[lo_orderdate]
--------------------PhysicalProject
----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_custkey = customer.c_custkey)) otherCondition=() build RFs:RF1 c_custkey->[lo_custkey]
------------------------PhysicalProject
--------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((lineorder.lo_suppkey = supplier.s_suppkey)) otherCondition=() build RFs:RF0 s_suppkey->[lo_suppkey]
----------------------------PhysicalProject
------------------------------PhysicalOlapScan[lineorder] apply RFs: RF0 RF1 RF2
----------------------------PhysicalProject
------------------------------filter(s_city IN ('UNITED KI1', 'UNITED KI5'))
--------------------------------PhysicalOlapScan[supplier]
------------------------PhysicalProject
--------------------------filter(c_city IN ('UNITED KI1', 'UNITED KI5'))
----------------------------PhysicalOlapScan[customer]
--------------------PhysicalProject
----------------------filter((dates.d_yearmonth = 'Dec1997'))
------------------------PhysicalOlapScan[dates]

Loading

0 comments on commit 8748b2e

Please sign in to comment.