You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jc...@apache.org on 2018/07/19 21:24:19 UTC

[06/13] hive git commit: HIVE-17896: TopNKey: Create a standalone vectorizable TopNKey operator (Teddy Choi, reviewed by Jesus Camacho Rodriguez)

http://git-wip-us.apache.org/repos/asf/hive/blob/cc294d32/ql/src/test/results/clientpositive/perf/tez/query45.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query45.q.out b/ql/src/test/results/clientpositive/perf/tez/query45.q.out
index 704af01..76f1a23 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query45.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query45.q.out
@@ -1,4 +1,4 @@
-Warning: Shuffle Join MERGEJOIN[87][tables = [$hdt$_0, $hdt$_1, $hdt$_2, $hdt$_3]] in Stage 'Reducer 4' is a cross product
+Warning: Shuffle Join MERGEJOIN[88][tables = [$hdt$_0, $hdt$_1, $hdt$_2, $hdt$_3]] in Stage 'Reducer 4' is a cross product
 PREHOOK: query: explain
 select  ca_zip, ca_county, sum(ws_sales_price)
  from web_sales, customer, customer_address, date_dim, item
@@ -56,125 +56,127 @@ Stage-0
     limit:100
     Stage-1
       Reducer 6 vectorized
-      File Output Operator [FS_120]
-        Limit [LIM_119] (rows=100 width=152)
+      File Output Operator [FS_121]
+        Limit [LIM_120] (rows=100 width=152)
           Number of rows:100
-          Select Operator [SEL_118] (rows=95833781 width=152)
+          Select Operator [SEL_119] (rows=95833781 width=152)
             Output:["_col0","_col1","_col2"]
           <-Reducer 5 [SIMPLE_EDGE] vectorized
-            SHUFFLE [RS_117]
-              Group By Operator [GBY_116] (rows=95833781 width=152)
+            SHUFFLE [RS_118]
+              Group By Operator [GBY_117] (rows=95833781 width=152)
                 Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1
               <-Reducer 4 [SIMPLE_EDGE]
                 SHUFFLE [RS_53]
                   PartitionCols:_col0, _col1
                   Group By Operator [GBY_52] (rows=191667562 width=152)
                     Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)"],keys:_col8, _col7
-                    Select Operator [SEL_51] (rows=191667562 width=152)
-                      Output:["_col3","_col7","_col8"]
-                      Filter Operator [FIL_50] (rows=191667562 width=152)
-                        predicate:((substr(_col8, 1, 5)) IN ('85669', '86197', '88274', '83405', '86475', '85392', '85460', '80348', '81792') or CASE WHEN ((_col14 = 0L)) THEN (false) WHEN (_col17 is not null) THEN (true) WHEN (_col13 is null) THEN (null) WHEN ((_col15 < _col14)) THEN (null) ELSE (false) END)
-                        Select Operator [SEL_49] (rows=191667562 width=152)
-                          Output:["_col3","_col7","_col8","_col13","_col14","_col15","_col17"]
-                          Merge Join Operator [MERGEJOIN_87] (rows=191667562 width=152)
-                            Conds:(Inner),Output:["_col3","_col4","_col6","_col8","_col12","_col16","_col17"]
-                          <-Reducer 12 [CUSTOM_SIMPLE_EDGE] vectorized
-                            PARTITION_ONLY_SHUFFLE [RS_115]
-                              Group By Operator [GBY_114] (rows=1 width=16)
-                                Output:["_col0","_col1"],aggregations:["count(VALUE._col0)","count(VALUE._col1)"]
-                              <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized
-                                SHUFFLE [RS_104]
-                                  Group By Operator [GBY_102] (rows=1 width=16)
-                                    Output:["_col0","_col1"],aggregations:["count()","count(i_item_id)"]
-                                    Select Operator [SEL_99] (rows=231000 width=1436)
-                                      Output:["i_item_id"]
-                                      Filter Operator [FIL_96] (rows=231000 width=1436)
-                                        predicate:(i_item_sk) IN (2, 3, 5, 7, 11, 13, 17, 19, 23, 29)
-                                        TableScan [TS_6] (rows=462000 width=1436)
-                                          default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_item_id"]
-                          <-Reducer 3 [CUSTOM_SIMPLE_EDGE]
-                            PARTITION_ONLY_SHUFFLE [RS_46]
-                              Merge Join Operator [MERGEJOIN_86] (rows=191667562 width=135)
-                                Conds:RS_43._col0=RS_44._col6(Inner),Output:["_col3","_col4","_col6","_col8","_col12"]
-                              <-Reducer 10 [SIMPLE_EDGE]
-                                SHUFFLE [RS_44]
-                                  PartitionCols:_col6
-                                  Merge Join Operator [MERGEJOIN_85] (rows=174243235 width=135)
-                                    Conds:RS_29._col0=RS_30._col1(Inner),Output:["_col1","_col3","_col6","_col7"]
-                                  <-Reducer 14 [SIMPLE_EDGE]
-                                    SHUFFLE [RS_30]
-                                      PartitionCols:_col1
-                                      Merge Join Operator [MERGEJOIN_84] (rows=158402938 width=135)
-                                        Conds:RS_110._col0=RS_113._col0(Inner),Output:["_col1","_col2","_col3"]
-                                      <-Map 13 [SIMPLE_EDGE] vectorized
-                                        SHUFFLE [RS_110]
-                                          PartitionCols:_col0
-                                          Select Operator [SEL_109] (rows=144002668 width=135)
-                                            Output:["_col0","_col1","_col2","_col3"]
-                                            Filter Operator [FIL_108] (rows=144002668 width=135)
-                                              predicate:(ws_bill_customer_sk is not null and ws_item_sk is not null and ws_sold_date_sk is not null)
-                                              TableScan [TS_16] (rows=144002668 width=135)
-                                                default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_bill_customer_sk","ws_sales_price"]
-                                      <-Map 15 [SIMPLE_EDGE] vectorized
-                                        SHUFFLE [RS_113]
-                                          PartitionCols:_col0
-                                          Select Operator [SEL_112] (rows=18262 width=1119)
-                                            Output:["_col0"]
-                                            Filter Operator [FIL_111] (rows=18262 width=1119)
-                                              predicate:((d_qoy = 2) and (d_year = 2000) and d_date_sk is not null)
-                                              TableScan [TS_19] (rows=73049 width=1119)
-                                                default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_qoy"]
-                                  <-Reducer 9 [SIMPLE_EDGE]
-                                    SHUFFLE [RS_29]
-                                      PartitionCols:_col0
-                                      Merge Join Operator [MERGEJOIN_83] (rows=508200 width=1436)
-                                        Conds:RS_100._col1=RS_107._col0(Left Outer),Output:["_col0","_col1","_col3"]
-                                      <-Map 8 [SIMPLE_EDGE] vectorized
-                                        SHUFFLE [RS_100]
-                                          PartitionCols:_col1
-                                          Select Operator [SEL_97] (rows=462000 width=1436)
-                                            Output:["_col0","_col1"]
-                                            Filter Operator [FIL_94] (rows=462000 width=1436)
-                                              predicate:i_item_sk is not null
-                                               Please refer to the previous TableScan [TS_6]
-                                      <-Reducer 11 [ONE_TO_ONE_EDGE] vectorized
-                                        FORWARD [RS_107]
-                                          PartitionCols:_col0
-                                          Select Operator [SEL_106] (rows=115500 width=1436)
-                                            Output:["_col0","_col1"]
-                                            Group By Operator [GBY_105] (rows=115500 width=1436)
-                                              Output:["_col0"],keys:KEY._col0
-                                            <-Map 8 [SIMPLE_EDGE] vectorized
-                                              SHUFFLE [RS_103]
-                                                PartitionCols:_col0
-                                                Group By Operator [GBY_101] (rows=231000 width=1436)
-                                                  Output:["_col0"],keys:i_item_id
-                                                  Select Operator [SEL_98] (rows=231000 width=1436)
-                                                    Output:["i_item_id"]
-                                                    Filter Operator [FIL_95] (rows=231000 width=1436)
-                                                      predicate:(i_item_sk) IN (2, 3, 5, 7, 11, 13, 17, 19, 23, 29)
-                                                       Please refer to the previous TableScan [TS_6]
-                              <-Reducer 2 [SIMPLE_EDGE]
-                                SHUFFLE [RS_43]
-                                  PartitionCols:_col0
-                                  Merge Join Operator [MERGEJOIN_82] (rows=88000001 width=860)
-                                    Conds:RS_90._col1=RS_93._col0(Inner),Output:["_col0","_col3","_col4"]
-                                  <-Map 1 [SIMPLE_EDGE] vectorized
-                                    SHUFFLE [RS_90]
-                                      PartitionCols:_col1
-                                      Select Operator [SEL_89] (rows=80000000 width=860)
-                                        Output:["_col0","_col1"]
-                                        Filter Operator [FIL_88] (rows=80000000 width=860)
-                                          predicate:(c_current_addr_sk is not null and c_customer_sk is not null)
-                                          TableScan [TS_0] (rows=80000000 width=860)
-                                            default@customer,customer,Tbl:COMPLETE,Col:NONE,Output:["c_customer_sk","c_current_addr_sk"]
-                                  <-Map 7 [SIMPLE_EDGE] vectorized
-                                    SHUFFLE [RS_93]
-                                      PartitionCols:_col0
-                                      Select Operator [SEL_92] (rows=40000000 width=1014)
-                                        Output:["_col0","_col1","_col2"]
-                                        Filter Operator [FIL_91] (rows=40000000 width=1014)
-                                          predicate:ca_address_sk is not null
-                                          TableScan [TS_3] (rows=40000000 width=1014)
-                                            default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_county","ca_zip"]
+                    Top N Key Operator [TNK_82] (rows=191667562 width=152)
+                      keys:_col8, _col7,sort order:++,top n:100
+                      Select Operator [SEL_51] (rows=191667562 width=152)
+                        Output:["_col3","_col7","_col8"]
+                        Filter Operator [FIL_50] (rows=191667562 width=152)
+                          predicate:((substr(_col8, 1, 5)) IN ('85669', '86197', '88274', '83405', '86475', '85392', '85460', '80348', '81792') or CASE WHEN ((_col14 = 0L)) THEN (false) WHEN (_col17 is not null) THEN (true) WHEN (_col13 is null) THEN (null) WHEN ((_col15 < _col14)) THEN (null) ELSE (false) END)
+                          Select Operator [SEL_49] (rows=191667562 width=152)
+                            Output:["_col3","_col7","_col8","_col13","_col14","_col15","_col17"]
+                            Merge Join Operator [MERGEJOIN_88] (rows=191667562 width=152)
+                              Conds:(Inner),Output:["_col3","_col4","_col6","_col8","_col12","_col16","_col17"]
+                            <-Reducer 12 [CUSTOM_SIMPLE_EDGE] vectorized
+                              PARTITION_ONLY_SHUFFLE [RS_116]
+                                Group By Operator [GBY_115] (rows=1 width=16)
+                                  Output:["_col0","_col1"],aggregations:["count(VALUE._col0)","count(VALUE._col1)"]
+                                <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized
+                                  SHUFFLE [RS_105]
+                                    Group By Operator [GBY_103] (rows=1 width=16)
+                                      Output:["_col0","_col1"],aggregations:["count()","count(i_item_id)"]
+                                      Select Operator [SEL_100] (rows=231000 width=1436)
+                                        Output:["i_item_id"]
+                                        Filter Operator [FIL_97] (rows=231000 width=1436)
+                                          predicate:(i_item_sk) IN (2, 3, 5, 7, 11, 13, 17, 19, 23, 29)
+                                          TableScan [TS_6] (rows=462000 width=1436)
+                                            default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_item_id"]
+                            <-Reducer 3 [CUSTOM_SIMPLE_EDGE]
+                              PARTITION_ONLY_SHUFFLE [RS_46]
+                                Merge Join Operator [MERGEJOIN_87] (rows=191667562 width=135)
+                                  Conds:RS_43._col0=RS_44._col6(Inner),Output:["_col3","_col4","_col6","_col8","_col12"]
+                                <-Reducer 10 [SIMPLE_EDGE]
+                                  SHUFFLE [RS_44]
+                                    PartitionCols:_col6
+                                    Merge Join Operator [MERGEJOIN_86] (rows=174243235 width=135)
+                                      Conds:RS_29._col0=RS_30._col1(Inner),Output:["_col1","_col3","_col6","_col7"]
+                                    <-Reducer 14 [SIMPLE_EDGE]
+                                      SHUFFLE [RS_30]
+                                        PartitionCols:_col1
+                                        Merge Join Operator [MERGEJOIN_85] (rows=158402938 width=135)
+                                          Conds:RS_111._col0=RS_114._col0(Inner),Output:["_col1","_col2","_col3"]
+                                        <-Map 13 [SIMPLE_EDGE] vectorized
+                                          SHUFFLE [RS_111]
+                                            PartitionCols:_col0
+                                            Select Operator [SEL_110] (rows=144002668 width=135)
+                                              Output:["_col0","_col1","_col2","_col3"]
+                                              Filter Operator [FIL_109] (rows=144002668 width=135)
+                                                predicate:(ws_bill_customer_sk is not null and ws_item_sk is not null and ws_sold_date_sk is not null)
+                                                TableScan [TS_16] (rows=144002668 width=135)
+                                                  default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_bill_customer_sk","ws_sales_price"]
+                                        <-Map 15 [SIMPLE_EDGE] vectorized
+                                          SHUFFLE [RS_114]
+                                            PartitionCols:_col0
+                                            Select Operator [SEL_113] (rows=18262 width=1119)
+                                              Output:["_col0"]
+                                              Filter Operator [FIL_112] (rows=18262 width=1119)
+                                                predicate:((d_qoy = 2) and (d_year = 2000) and d_date_sk is not null)
+                                                TableScan [TS_19] (rows=73049 width=1119)
+                                                  default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_qoy"]
+                                    <-Reducer 9 [SIMPLE_EDGE]
+                                      SHUFFLE [RS_29]
+                                        PartitionCols:_col0
+                                        Merge Join Operator [MERGEJOIN_84] (rows=508200 width=1436)
+                                          Conds:RS_101._col1=RS_108._col0(Left Outer),Output:["_col0","_col1","_col3"]
+                                        <-Map 8 [SIMPLE_EDGE] vectorized
+                                          SHUFFLE [RS_101]
+                                            PartitionCols:_col1
+                                            Select Operator [SEL_98] (rows=462000 width=1436)
+                                              Output:["_col0","_col1"]
+                                              Filter Operator [FIL_95] (rows=462000 width=1436)
+                                                predicate:i_item_sk is not null
+                                                 Please refer to the previous TableScan [TS_6]
+                                        <-Reducer 11 [ONE_TO_ONE_EDGE] vectorized
+                                          FORWARD [RS_108]
+                                            PartitionCols:_col0
+                                            Select Operator [SEL_107] (rows=115500 width=1436)
+                                              Output:["_col0","_col1"]
+                                              Group By Operator [GBY_106] (rows=115500 width=1436)
+                                                Output:["_col0"],keys:KEY._col0
+                                              <-Map 8 [SIMPLE_EDGE] vectorized
+                                                SHUFFLE [RS_104]
+                                                  PartitionCols:_col0
+                                                  Group By Operator [GBY_102] (rows=231000 width=1436)
+                                                    Output:["_col0"],keys:i_item_id
+                                                    Select Operator [SEL_99] (rows=231000 width=1436)
+                                                      Output:["i_item_id"]
+                                                      Filter Operator [FIL_96] (rows=231000 width=1436)
+                                                        predicate:(i_item_sk) IN (2, 3, 5, 7, 11, 13, 17, 19, 23, 29)
+                                                         Please refer to the previous TableScan [TS_6]
+                                <-Reducer 2 [SIMPLE_EDGE]
+                                  SHUFFLE [RS_43]
+                                    PartitionCols:_col0
+                                    Merge Join Operator [MERGEJOIN_83] (rows=88000001 width=860)
+                                      Conds:RS_91._col1=RS_94._col0(Inner),Output:["_col0","_col3","_col4"]
+                                    <-Map 1 [SIMPLE_EDGE] vectorized
+                                      SHUFFLE [RS_91]
+                                        PartitionCols:_col1
+                                        Select Operator [SEL_90] (rows=80000000 width=860)
+                                          Output:["_col0","_col1"]
+                                          Filter Operator [FIL_89] (rows=80000000 width=860)
+                                            predicate:(c_current_addr_sk is not null and c_customer_sk is not null)
+                                            TableScan [TS_0] (rows=80000000 width=860)
+                                              default@customer,customer,Tbl:COMPLETE,Col:NONE,Output:["c_customer_sk","c_current_addr_sk"]
+                                    <-Map 7 [SIMPLE_EDGE] vectorized
+                                      SHUFFLE [RS_94]
+                                        PartitionCols:_col0
+                                        Select Operator [SEL_93] (rows=40000000 width=1014)
+                                          Output:["_col0","_col1","_col2"]
+                                          Filter Operator [FIL_92] (rows=40000000 width=1014)
+                                            predicate:ca_address_sk is not null
+                                            TableScan [TS_3] (rows=40000000 width=1014)
+                                              default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_county","ca_zip"]
 

http://git-wip-us.apache.org/repos/asf/hive/blob/cc294d32/ql/src/test/results/clientpositive/perf/tez/query49.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query49.q.out b/ql/src/test/results/clientpositive/perf/tez/query49.q.out
index 47f37a2..2c2c42e 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query49.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query49.q.out
@@ -277,220 +277,224 @@ Stage-0
     limit:100
     Stage-1
       Reducer 11 vectorized
-      File Output Operator [FS_205]
-        Limit [LIM_204] (rows=100 width=101)
+      File Output Operator [FS_209]
+        Limit [LIM_208] (rows=100 width=101)
           Number of rows:100
-          Select Operator [SEL_203] (rows=5915494 width=101)
+          Select Operator [SEL_207] (rows=5915494 width=101)
             Output:["_col0","_col1","_col2","_col3","_col4"]
           <-Reducer 10 [SIMPLE_EDGE] vectorized
-            SHUFFLE [RS_202]
-              Select Operator [SEL_201] (rows=5915494 width=101)
+            SHUFFLE [RS_206]
+              Select Operator [SEL_205] (rows=5915494 width=101)
                 Output:["_col0","_col1","_col2","_col3","_col4"]
-                Group By Operator [GBY_200] (rows=5915494 width=101)
+                Group By Operator [GBY_204] (rows=5915494 width=101)
                   Output:["_col0","_col1","_col2","_col3","_col4"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4
                 <-Union 9 [SIMPLE_EDGE]
                   <-Reducer 22 [CONTAINS] vectorized
-                    Reduce Output Operator [RS_241]
+                    Reduce Output Operator [RS_246]
                       PartitionCols:_col0, _col1, _col2, _col3, _col4
-                      Group By Operator [GBY_240] (rows=11830988 width=101)
+                      Group By Operator [GBY_245] (rows=11830988 width=101)
                         Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2
-                        Select Operator [SEL_239] (rows=8604378 width=88)
-                          Output:["_col0","_col1","_col2","_col3","_col4"]
-                          Filter Operator [FIL_238] (rows=8604378 width=88)
-                            predicate:((_col0 <= 10) or (rank_window_1 <= 10))
-                            PTF Operator [PTF_237] (rows=12906568 width=88)
-                              Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
-                              Select Operator [SEL_236] (rows=12906568 width=88)
-                                Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                              <-Reducer 21 [SIMPLE_EDGE] vectorized
-                                SHUFFLE [RS_235]
-                                  PartitionCols:0
-                                  Select Operator [SEL_234] (rows=12906568 width=88)
-                                    Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"]
-                                    PTF Operator [PTF_233] (rows=12906568 width=88)
-                                      Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
-                                      Select Operator [SEL_232] (rows=12906568 width=88)
-                                        Output:["_col0","_col1","_col2","_col3","_col4"]
-                                      <-Reducer 20 [SIMPLE_EDGE] vectorized
-                                        SHUFFLE [RS_231]
-                                          PartitionCols:0
-                                          Group By Operator [GBY_230] (rows=12906568 width=88)
-                                            Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0
-                                          <-Reducer 19 [SIMPLE_EDGE]
-                                            SHUFFLE [RS_89]
-                                              PartitionCols:_col0
-                                              Group By Operator [GBY_88] (rows=25813137 width=88)
-                                                Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col1)","sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0
-                                                Select Operator [SEL_86] (rows=25813137 width=88)
-                                                  Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                  Merge Join Operator [MERGEJOIN_146] (rows=25813137 width=88)
-                                                    Conds:RS_83._col1, _col2=RS_229._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"]
-                                                  <-Map 27 [SIMPLE_EDGE] vectorized
-                                                    SHUFFLE [RS_229]
-                                                      PartitionCols:_col0, _col1
-                                                      Select Operator [SEL_228] (rows=19197050 width=77)
-                                                        Output:["_col0","_col1","_col2","_col3"]
-                                                        Filter Operator [FIL_227] (rows=19197050 width=77)
-                                                          predicate:((sr_return_amt > 10000) and sr_item_sk is not null and sr_ticket_number is not null)
-                                                          TableScan [TS_77] (rows=57591150 width=77)
-                                                            default@store_returns,sr,Tbl:COMPLETE,Col:NONE,Output:["sr_item_sk","sr_ticket_number","sr_return_quantity","sr_return_amt"]
-                                                  <-Reducer 18 [SIMPLE_EDGE]
-                                                    SHUFFLE [RS_83]
-                                                      PartitionCols:_col1, _col2
-                                                      Merge Join Operator [MERGEJOIN_145] (rows=23466488 width=88)
-                                                        Conds:RS_226._col0=RS_180._col0(Inner),Output:["_col1","_col2","_col3","_col4"]
-                                                      <-Map 12 [SIMPLE_EDGE] vectorized
-                                                        SHUFFLE [RS_180]
-                                                          PartitionCols:_col0
-                                                          Select Operator [SEL_177] (rows=18262 width=1119)
-                                                            Output:["_col0"]
-                                                            Filter Operator [FIL_176] (rows=18262 width=1119)
-                                                              predicate:((d_moy = 12) and (d_year = 2000) and d_date_sk is not null)
-                                                              TableScan [TS_3] (rows=73049 width=1119)
-                                                                default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
-                                                      <-Map 26 [SIMPLE_EDGE] vectorized
-                                                        SHUFFLE [RS_226]
-                                                          PartitionCols:_col0
-                                                          Select Operator [SEL_225] (rows=21333171 width=88)
-                                                            Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                            Filter Operator [FIL_224] (rows=21333171 width=88)
-                                                              predicate:((ss_net_paid > 0) and (ss_net_profit > 1) and (ss_quantity > 0) and ss_item_sk is not null and ss_sold_date_sk is not null and ss_ticket_number is not null)
-                                                              TableScan [TS_71] (rows=575995635 width=88)
-                                                                default@store_sales,sts,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_ticket_number","ss_quantity","ss_net_paid","ss_net_profit"]
+                        Top N Key Operator [TNK_244] (rows=11830988 width=101)
+                          keys:_col0, _col3, _col4, _col1, _col2,sort order:+++++,top n:100
+                          Select Operator [SEL_243] (rows=8604378 width=88)
+                            Output:["_col0","_col1","_col2","_col3","_col4"]
+                            Filter Operator [FIL_242] (rows=8604378 width=88)
+                              predicate:((_col0 <= 10) or (rank_window_1 <= 10))
+                              PTF Operator [PTF_241] (rows=12906568 width=88)
+                                Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
+                                Select Operator [SEL_240] (rows=12906568 width=88)
+                                  Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
+                                <-Reducer 21 [SIMPLE_EDGE] vectorized
+                                  SHUFFLE [RS_239]
+                                    PartitionCols:0
+                                    Select Operator [SEL_238] (rows=12906568 width=88)
+                                      Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"]
+                                      PTF Operator [PTF_237] (rows=12906568 width=88)
+                                        Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
+                                        Select Operator [SEL_236] (rows=12906568 width=88)
+                                          Output:["_col0","_col1","_col2","_col3","_col4"]
+                                        <-Reducer 20 [SIMPLE_EDGE] vectorized
+                                          SHUFFLE [RS_235]
+                                            PartitionCols:0
+                                            Group By Operator [GBY_234] (rows=12906568 width=88)
+                                              Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0
+                                            <-Reducer 19 [SIMPLE_EDGE]
+                                              SHUFFLE [RS_89]
+                                                PartitionCols:_col0
+                                                Group By Operator [GBY_88] (rows=25813137 width=88)
+                                                  Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col1)","sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0
+                                                  Select Operator [SEL_86] (rows=25813137 width=88)
+                                                    Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                    Merge Join Operator [MERGEJOIN_147] (rows=25813137 width=88)
+                                                      Conds:RS_83._col1, _col2=RS_233._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"]
+                                                    <-Map 27 [SIMPLE_EDGE] vectorized
+                                                      SHUFFLE [RS_233]
+                                                        PartitionCols:_col0, _col1
+                                                        Select Operator [SEL_232] (rows=19197050 width=77)
+                                                          Output:["_col0","_col1","_col2","_col3"]
+                                                          Filter Operator [FIL_231] (rows=19197050 width=77)
+                                                            predicate:((sr_return_amt > 10000) and sr_item_sk is not null and sr_ticket_number is not null)
+                                                            TableScan [TS_77] (rows=57591150 width=77)
+                                                              default@store_returns,sr,Tbl:COMPLETE,Col:NONE,Output:["sr_item_sk","sr_ticket_number","sr_return_quantity","sr_return_amt"]
+                                                    <-Reducer 18 [SIMPLE_EDGE]
+                                                      SHUFFLE [RS_83]
+                                                        PartitionCols:_col1, _col2
+                                                        Merge Join Operator [MERGEJOIN_146] (rows=23466488 width=88)
+                                                          Conds:RS_230._col0=RS_183._col0(Inner),Output:["_col1","_col2","_col3","_col4"]
+                                                        <-Map 12 [SIMPLE_EDGE] vectorized
+                                                          SHUFFLE [RS_183]
+                                                            PartitionCols:_col0
+                                                            Select Operator [SEL_180] (rows=18262 width=1119)
+                                                              Output:["_col0"]
+                                                              Filter Operator [FIL_179] (rows=18262 width=1119)
+                                                                predicate:((d_moy = 12) and (d_year = 2000) and d_date_sk is not null)
+                                                                TableScan [TS_3] (rows=73049 width=1119)
+                                                                  default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
+                                                        <-Map 26 [SIMPLE_EDGE] vectorized
+                                                          SHUFFLE [RS_230]
+                                                            PartitionCols:_col0
+                                                            Select Operator [SEL_229] (rows=21333171 width=88)
+                                                              Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                              Filter Operator [FIL_228] (rows=21333171 width=88)
+                                                                predicate:((ss_net_paid > 0) and (ss_net_profit > 1) and (ss_quantity > 0) and ss_item_sk is not null and ss_sold_date_sk is not null and ss_ticket_number is not null)
+                                                                TableScan [TS_71] (rows=575995635 width=88)
+                                                                  default@store_sales,sts,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_ticket_number","ss_quantity","ss_net_paid","ss_net_profit"]
                   <-Reducer 8 [CONTAINS] vectorized
-                    Reduce Output Operator [RS_199]
+                    Reduce Output Operator [RS_203]
                       PartitionCols:_col0, _col1, _col2, _col3, _col4
-                      Group By Operator [GBY_198] (rows=11830988 width=101)
+                      Group By Operator [GBY_202] (rows=11830988 width=101)
                         Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2
-                        Select Operator [SEL_197] (rows=3226610 width=135)
-                          Output:["_col0","_col1","_col2","_col3","_col4"]
-                          Group By Operator [GBY_196] (rows=3226610 width=135)
-                            Output:["_col0","_col1","_col2","_col3","_col4"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4
-                          <-Union 7 [SIMPLE_EDGE]
-                            <-Reducer 17 [CONTAINS] vectorized
-                              Reduce Output Operator [RS_223]
-                                PartitionCols:_col0, _col1, _col2, _col3, _col4
-                                Group By Operator [GBY_222] (rows=6453220 width=135)
-                                  Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2
-                                  Select Operator [SEL_221] (rows=4302070 width=135)
-                                    Output:["_col0","_col1","_col2","_col3","_col4"]
-                                    Filter Operator [FIL_220] (rows=4302070 width=135)
-                                      predicate:((_col0 <= 10) or (rank_window_1 <= 10))
-                                      PTF Operator [PTF_219] (rows=6453105 width=135)
-                                        Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
-                                        Select Operator [SEL_218] (rows=6453105 width=135)
-                                          Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                                        <-Reducer 16 [SIMPLE_EDGE] vectorized
-                                          SHUFFLE [RS_217]
-                                            PartitionCols:0
-                                            Select Operator [SEL_216] (rows=6453105 width=135)
-                                              Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"]
-                                              PTF Operator [PTF_215] (rows=6453105 width=135)
-                                                Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
-                                                Select Operator [SEL_214] (rows=6453105 width=135)
-                                                  Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                <-Reducer 15 [SIMPLE_EDGE] vectorized
-                                                  SHUFFLE [RS_213]
-                                                    PartitionCols:0
-                                                    Group By Operator [GBY_212] (rows=6453105 width=135)
-                                                      Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0
-                                                    <-Reducer 14 [SIMPLE_EDGE]
-                                                      SHUFFLE [RS_50]
-                                                        PartitionCols:_col0
-                                                        Group By Operator [GBY_49] (rows=12906211 width=135)
-                                                          Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col1)","sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0
-                                                          Select Operator [SEL_47] (rows=12906211 width=135)
-                                                            Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                            Merge Join Operator [MERGEJOIN_144] (rows=12906211 width=135)
-                                                              Conds:RS_44._col1, _col2=RS_211._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"]
-                                                            <-Map 25 [SIMPLE_EDGE] vectorized
-                                                              SHUFFLE [RS_211]
-                                                                PartitionCols:_col0, _col1
-                                                                Select Operator [SEL_210] (rows=9599627 width=106)
-                                                                  Output:["_col0","_col1","_col2","_col3"]
-                                                                  Filter Operator [FIL_209] (rows=9599627 width=106)
-                                                                    predicate:((cr_return_amount > 10000) and cr_item_sk is not null and cr_order_number is not null)
-                                                                    TableScan [TS_38] (rows=28798881 width=106)
-                                                                      default@catalog_returns,cr,Tbl:COMPLETE,Col:NONE,Output:["cr_item_sk","cr_order_number","cr_return_quantity","cr_return_amount"]
-                                                            <-Reducer 13 [SIMPLE_EDGE]
-                                                              SHUFFLE [RS_44]
-                                                                PartitionCols:_col1, _col2
-                                                                Merge Join Operator [MERGEJOIN_143] (rows=11732919 width=135)
-                                                                  Conds:RS_208._col0=RS_179._col0(Inner),Output:["_col1","_col2","_col3","_col4"]
-                                                                <-Map 12 [SIMPLE_EDGE] vectorized
-                                                                  SHUFFLE [RS_179]
-                                                                    PartitionCols:_col0
-                                                                     Please refer to the previous Select Operator [SEL_177]
-                                                                <-Map 24 [SIMPLE_EDGE] vectorized
-                                                                  SHUFFLE [RS_208]
-                                                                    PartitionCols:_col0
-                                                                    Select Operator [SEL_207] (rows=10666290 width=135)
-                                                                      Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                                      Filter Operator [FIL_206] (rows=10666290 width=135)
-                                                                        predicate:((cs_net_paid > 0) and (cs_net_profit > 1) and (cs_quantity > 0) and cs_item_sk is not null and cs_order_number is not null and cs_sold_date_sk is not null)
-                                                                        TableScan [TS_32] (rows=287989836 width=135)
-                                                                          default@catalog_sales,cs,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk","cs_order_number","cs_quantity","cs_net_paid","cs_net_profit"]
-                            <-Reducer 6 [CONTAINS] vectorized
-                              Reduce Output Operator [RS_195]
-                                PartitionCols:_col0, _col1, _col2, _col3, _col4
-                                Group By Operator [GBY_194] (rows=6453220 width=135)
-                                  Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2
-                                  Select Operator [SEL_193] (rows=2151150 width=135)
-                                    Output:["_col0","_col1","_col2","_col3","_col4"]
-                                    Filter Operator [FIL_192] (rows=2151150 width=135)
-                                      predicate:((_col0 <= 10) or (rank_window_1 <= 10))
-                                      PTF Operator [PTF_191] (rows=3226726 width=135)
-                                        Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
-                                        Select Operator [SEL_190] (rows=3226726 width=135)
-                                          Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                                        <-Reducer 5 [SIMPLE_EDGE] vectorized
-                                          SHUFFLE [RS_189]
-                                            PartitionCols:0
-                                            Select Operator [SEL_188] (rows=3226726 width=135)
-                                              Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"]
-                                              PTF Operator [PTF_187] (rows=3226726 width=135)
-                                                Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
-                                                Select Operator [SEL_186] (rows=3226726 width=135)
-                                                  Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                <-Reducer 4 [SIMPLE_EDGE] vectorized
-                                                  SHUFFLE [RS_185]
-                                                    PartitionCols:0
-                                                    Group By Operator [GBY_184] (rows=3226726 width=135)
-                                                      Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0
-                                                    <-Reducer 3 [SIMPLE_EDGE]
-                                                      SHUFFLE [RS_18]
-                                                        PartitionCols:_col0
-                                                        Group By Operator [GBY_17] (rows=6453452 width=135)
-                                                          Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col1)","sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0
-                                                          Select Operator [SEL_15] (rows=6453452 width=135)
-                                                            Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                            Merge Join Operator [MERGEJOIN_142] (rows=6453452 width=135)
-                                                              Conds:RS_12._col1, _col2=RS_183._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"]
-                                                            <-Map 23 [SIMPLE_EDGE] vectorized
-                                                              SHUFFLE [RS_183]
-                                                                PartitionCols:_col0, _col1
-                                                                Select Operator [SEL_182] (rows=4799489 width=92)
-                                                                  Output:["_col0","_col1","_col2","_col3"]
-                                                                  Filter Operator [FIL_181] (rows=4799489 width=92)
-                                                                    predicate:((wr_return_amt > 10000) and wr_item_sk is not null and wr_order_number is not null)
-                                                                    TableScan [TS_6] (rows=14398467 width=92)
-                                                                      default@web_returns,wr,Tbl:COMPLETE,Col:NONE,Output:["wr_item_sk","wr_order_number","wr_return_quantity","wr_return_amt"]
-                                                            <-Reducer 2 [SIMPLE_EDGE]
-                                                              SHUFFLE [RS_12]
-                                                                PartitionCols:_col1, _col2
-                                                                Merge Join Operator [MERGEJOIN_141] (rows=5866775 width=135)
-                                                                  Conds:RS_175._col0=RS_178._col0(Inner),Output:["_col1","_col2","_col3","_col4"]
-                                                                <-Map 12 [SIMPLE_EDGE] vectorized
-                                                                  SHUFFLE [RS_178]
-                                                                    PartitionCols:_col0
-                                                                     Please refer to the previous Select Operator [SEL_177]
-                                                                <-Map 1 [SIMPLE_EDGE] vectorized
-                                                                  SHUFFLE [RS_175]
-                                                                    PartitionCols:_col0
-                                                                    Select Operator [SEL_174] (rows=5333432 width=135)
-                                                                      Output:["_col0","_col1","_col2","_col3","_col4"]
-                                                                      Filter Operator [FIL_173] (rows=5333432 width=135)
-                                                                        predicate:((ws_net_paid > 0) and (ws_net_profit > 1) and (ws_quantity > 0) and ws_item_sk is not null and ws_order_number is not null and ws_sold_date_sk is not null)
-                                                                        TableScan [TS_0] (rows=144002668 width=135)
-                                                                          default@web_sales,ws,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_order_number","ws_quantity","ws_net_paid","ws_net_profit"]
+                        Top N Key Operator [TNK_201] (rows=11830988 width=101)
+                          keys:_col0, _col3, _col4, _col1, _col2,sort order:+++++,top n:100
+                          Select Operator [SEL_200] (rows=3226610 width=135)
+                            Output:["_col0","_col1","_col2","_col3","_col4"]
+                            Group By Operator [GBY_199] (rows=3226610 width=135)
+                              Output:["_col0","_col1","_col2","_col3","_col4"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4
+                            <-Union 7 [SIMPLE_EDGE]
+                              <-Reducer 17 [CONTAINS] vectorized
+                                Reduce Output Operator [RS_227]
+                                  PartitionCols:_col0, _col1, _col2, _col3, _col4
+                                  Group By Operator [GBY_226] (rows=6453220 width=135)
+                                    Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2
+                                    Select Operator [SEL_225] (rows=4302070 width=135)
+                                      Output:["_col0","_col1","_col2","_col3","_col4"]
+                                      Filter Operator [FIL_224] (rows=4302070 width=135)
+                                        predicate:((_col0 <= 10) or (rank_window_1 <= 10))
+                                        PTF Operator [PTF_223] (rows=6453105 width=135)
+                                          Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
+                                          Select Operator [SEL_222] (rows=6453105 width=135)
+                                            Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
+                                          <-Reducer 16 [SIMPLE_EDGE] vectorized
+                                            SHUFFLE [RS_221]
+                                              PartitionCols:0
+                                              Select Operator [SEL_220] (rows=6453105 width=135)
+                                                Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"]
+                                                PTF Operator [PTF_219] (rows=6453105 width=135)
+                                                  Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
+                                                  Select Operator [SEL_218] (rows=6453105 width=135)
+                                                    Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                  <-Reducer 15 [SIMPLE_EDGE] vectorized
+                                                    SHUFFLE [RS_217]
+                                                      PartitionCols:0
+                                                      Group By Operator [GBY_216] (rows=6453105 width=135)
+                                                        Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0
+                                                      <-Reducer 14 [SIMPLE_EDGE]
+                                                        SHUFFLE [RS_50]
+                                                          PartitionCols:_col0
+                                                          Group By Operator [GBY_49] (rows=12906211 width=135)
+                                                            Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col1)","sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0
+                                                            Select Operator [SEL_47] (rows=12906211 width=135)
+                                                              Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                              Merge Join Operator [MERGEJOIN_145] (rows=12906211 width=135)
+                                                                Conds:RS_44._col1, _col2=RS_215._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"]
+                                                              <-Map 25 [SIMPLE_EDGE] vectorized
+                                                                SHUFFLE [RS_215]
+                                                                  PartitionCols:_col0, _col1
+                                                                  Select Operator [SEL_214] (rows=9599627 width=106)
+                                                                    Output:["_col0","_col1","_col2","_col3"]
+                                                                    Filter Operator [FIL_213] (rows=9599627 width=106)
+                                                                      predicate:((cr_return_amount > 10000) and cr_item_sk is not null and cr_order_number is not null)
+                                                                      TableScan [TS_38] (rows=28798881 width=106)
+                                                                        default@catalog_returns,cr,Tbl:COMPLETE,Col:NONE,Output:["cr_item_sk","cr_order_number","cr_return_quantity","cr_return_amount"]
+                                                              <-Reducer 13 [SIMPLE_EDGE]
+                                                                SHUFFLE [RS_44]
+                                                                  PartitionCols:_col1, _col2
+                                                                  Merge Join Operator [MERGEJOIN_144] (rows=11732919 width=135)
+                                                                    Conds:RS_212._col0=RS_182._col0(Inner),Output:["_col1","_col2","_col3","_col4"]
+                                                                  <-Map 12 [SIMPLE_EDGE] vectorized
+                                                                    SHUFFLE [RS_182]
+                                                                      PartitionCols:_col0
+                                                                       Please refer to the previous Select Operator [SEL_180]
+                                                                  <-Map 24 [SIMPLE_EDGE] vectorized
+                                                                    SHUFFLE [RS_212]
+                                                                      PartitionCols:_col0
+                                                                      Select Operator [SEL_211] (rows=10666290 width=135)
+                                                                        Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                                        Filter Operator [FIL_210] (rows=10666290 width=135)
+                                                                          predicate:((cs_net_paid > 0) and (cs_net_profit > 1) and (cs_quantity > 0) and cs_item_sk is not null and cs_order_number is not null and cs_sold_date_sk is not null)
+                                                                          TableScan [TS_32] (rows=287989836 width=135)
+                                                                            default@catalog_sales,cs,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk","cs_order_number","cs_quantity","cs_net_paid","cs_net_profit"]
+                              <-Reducer 6 [CONTAINS] vectorized
+                                Reduce Output Operator [RS_198]
+                                  PartitionCols:_col0, _col1, _col2, _col3, _col4
+                                  Group By Operator [GBY_197] (rows=6453220 width=135)
+                                    Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2
+                                    Select Operator [SEL_196] (rows=2151150 width=135)
+                                      Output:["_col0","_col1","_col2","_col3","_col4"]
+                                      Filter Operator [FIL_195] (rows=2151150 width=135)
+                                        predicate:((_col0 <= 10) or (rank_window_1 <= 10))
+                                        PTF Operator [PTF_194] (rows=3226726 width=135)
+                                          Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
+                                          Select Operator [SEL_193] (rows=3226726 width=135)
+                                            Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
+                                          <-Reducer 5 [SIMPLE_EDGE] vectorized
+                                            SHUFFLE [RS_192]
+                                              PartitionCols:0
+                                              Select Operator [SEL_191] (rows=3226726 width=135)
+                                                Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"]
+                                                PTF Operator [PTF_190] (rows=3226726 width=135)
+                                                  Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}]
+                                                  Select Operator [SEL_189] (rows=3226726 width=135)
+                                                    Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                  <-Reducer 4 [SIMPLE_EDGE] vectorized
+                                                    SHUFFLE [RS_188]
+                                                      PartitionCols:0
+                                                      Group By Operator [GBY_187] (rows=3226726 width=135)
+                                                        Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0
+                                                      <-Reducer 3 [SIMPLE_EDGE]
+                                                        SHUFFLE [RS_18]
+                                                          PartitionCols:_col0
+                                                          Group By Operator [GBY_17] (rows=6453452 width=135)
+                                                            Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col1)","sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0
+                                                            Select Operator [SEL_15] (rows=6453452 width=135)
+                                                              Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                              Merge Join Operator [MERGEJOIN_143] (rows=6453452 width=135)
+                                                                Conds:RS_12._col1, _col2=RS_186._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"]
+                                                              <-Map 23 [SIMPLE_EDGE] vectorized
+                                                                SHUFFLE [RS_186]
+                                                                  PartitionCols:_col0, _col1
+                                                                  Select Operator [SEL_185] (rows=4799489 width=92)
+                                                                    Output:["_col0","_col1","_col2","_col3"]
+                                                                    Filter Operator [FIL_184] (rows=4799489 width=92)
+                                                                      predicate:((wr_return_amt > 10000) and wr_item_sk is not null and wr_order_number is not null)
+                                                                      TableScan [TS_6] (rows=14398467 width=92)
+                                                                        default@web_returns,wr,Tbl:COMPLETE,Col:NONE,Output:["wr_item_sk","wr_order_number","wr_return_quantity","wr_return_amt"]
+                                                              <-Reducer 2 [SIMPLE_EDGE]
+                                                                SHUFFLE [RS_12]
+                                                                  PartitionCols:_col1, _col2
+                                                                  Merge Join Operator [MERGEJOIN_142] (rows=5866775 width=135)
+                                                                    Conds:RS_178._col0=RS_181._col0(Inner),Output:["_col1","_col2","_col3","_col4"]
+                                                                  <-Map 12 [SIMPLE_EDGE] vectorized
+                                                                    SHUFFLE [RS_181]
+                                                                      PartitionCols:_col0
+                                                                       Please refer to the previous Select Operator [SEL_180]
+                                                                  <-Map 1 [SIMPLE_EDGE] vectorized
+                                                                    SHUFFLE [RS_178]
+                                                                      PartitionCols:_col0
+                                                                      Select Operator [SEL_177] (rows=5333432 width=135)
+                                                                        Output:["_col0","_col1","_col2","_col3","_col4"]
+                                                                        Filter Operator [FIL_176] (rows=5333432 width=135)
+                                                                          predicate:((ws_net_paid > 0) and (ws_net_profit > 1) and (ws_quantity > 0) and ws_item_sk is not null and ws_order_number is not null and ws_sold_date_sk is not null)
+                                                                          TableScan [TS_0] (rows=144002668 width=135)
+                                                                            default@web_sales,ws,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_order_number","ws_quantity","ws_net_paid","ws_net_profit"]