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:22 UTC

[09/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/query14.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query14.q.out b/ql/src/test/results/clientpositive/perf/tez/query14.q.out
index 4d27064..43a19c0 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query14.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query14.q.out
@@ -1,6 +1,6 @@
-Warning: Shuffle Join MERGEJOIN[902][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 5' is a cross product
-Warning: Shuffle Join MERGEJOIN[914][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 12' is a cross product
-Warning: Shuffle Join MERGEJOIN[926][tables = [$hdt$_2, $hdt$_3, $hdt$_1]] in Stage 'Reducer 16' is a cross product
+Warning: Shuffle Join MERGEJOIN[903][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 5' is a cross product
+Warning: Shuffle Join MERGEJOIN[916][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 12' is a cross product
+Warning: Shuffle Join MERGEJOIN[929][tables = [$hdt$_2, $hdt$_3, $hdt$_1]] in Stage 'Reducer 16' is a cross product
 PREHOOK: query: explain
 with  cross_items as
  (select i_item_sk ss_item_sk
@@ -281,904 +281,910 @@ Stage-0
     limit:100
     Stage-1
       Reducer 8 vectorized
-      File Output Operator [FS_1134]
-        Limit [LIM_1133] (rows=100 width=237)
+      File Output Operator [FS_1138]
+        Limit [LIM_1137] (rows=100 width=237)
           Number of rows:100
-          Select Operator [SEL_1132] (rows=1016388080 width=237)
+          Select Operator [SEL_1136] (rows=1016388080 width=237)
             Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
           <-Reducer 7 [SIMPLE_EDGE] vectorized
-            SHUFFLE [RS_1131]
-              Select Operator [SEL_1130] (rows=1016388080 width=237)
+            SHUFFLE [RS_1135]
+              Select Operator [SEL_1134] (rows=1016388080 width=237)
                 Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                Group By Operator [GBY_1129] (rows=1016388080 width=237)
+                Group By Operator [GBY_1133] (rows=1016388080 width=237)
                   Output:["_col0","_col1","_col2","_col3","_col5","_col6"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4
                 <-Union 6 [SIMPLE_EDGE]
                   <-Reducer 12 [CONTAINS]
-                    Reduce Output Operator [RS_919]
+                    Reduce Output Operator [RS_922]
                       PartitionCols:_col0, _col1, _col2, _col3, _col4
-                      Group By Operator [GBY_918] (rows=2032776160 width=237)
+                      Group By Operator [GBY_921] (rows=2032776160 width=237)
                         Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(_col4)","sum(_col5)"],keys:_col0, _col1, _col2, _col3, 0L
-                        Select Operator [SEL_916] (rows=116155905 width=264)
-                          Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                          Filter Operator [FIL_915] (rows=116155905 width=264)
-                            predicate:(_col5 > _col1)
-                            Merge Join Operator [MERGEJOIN_914] (rows=348467716 width=264)
-                              Conds:(Inner),(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6"]
-                            <-Reducer 11 [CUSTOM_SIMPLE_EDGE] vectorized
-                              PARTITION_ONLY_SHUFFLE [RS_1140]
-                                Select Operator [SEL_1139] (rows=1 width=8)
-                                  Filter Operator [FIL_1138] (rows=1 width=8)
-                                    predicate:(sq_count_check(_col0) <= 1)
-                                    Group By Operator [GBY_1137] (rows=1 width=8)
-                                      Output:["_col0"],aggregations:["count()"]
-                                      Select Operator [SEL_1136] (rows=1 width=8)
-                                        Group By Operator [GBY_1135] (rows=1 width=8)
-                                          Output:["_col0"],aggregations:["count(VALUE._col0)"]
-                                        <-Union 10 [CUSTOM_SIMPLE_EDGE]
-                                          <-Reducer 19 [CONTAINS]
-                                            Reduce Output Operator [RS_943]
-                                              Group By Operator [GBY_942] (rows=1 width=8)
-                                                Output:["_col0"],aggregations:["count(_col0)"]
-                                                Select Operator [SEL_941] (rows=1108786976 width=108)
-                                                  Output:["_col0"]
-                                                  Select Operator [SEL_939] (rows=316788826 width=135)
+                        Top N Key Operator [TNK_920] (rows=406555232 width=237)
+                          keys:_col0, _col1, _col2, _col3, 0L,sort order:+++++,top n:100
+                          Select Operator [SEL_918] (rows=116155905 width=264)
+                            Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
+                            Filter Operator [FIL_917] (rows=116155905 width=264)
+                              predicate:(_col5 > _col1)
+                              Merge Join Operator [MERGEJOIN_916] (rows=348467716 width=264)
+                                Conds:(Inner),(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6"]
+                              <-Reducer 11 [CUSTOM_SIMPLE_EDGE] vectorized
+                                PARTITION_ONLY_SHUFFLE [RS_1144]
+                                  Select Operator [SEL_1143] (rows=1 width=8)
+                                    Filter Operator [FIL_1142] (rows=1 width=8)
+                                      predicate:(sq_count_check(_col0) <= 1)
+                                      Group By Operator [GBY_1141] (rows=1 width=8)
+                                        Output:["_col0"],aggregations:["count()"]
+                                        Select Operator [SEL_1140] (rows=1 width=8)
+                                          Group By Operator [GBY_1139] (rows=1 width=8)
+                                            Output:["_col0"],aggregations:["count(VALUE._col0)"]
+                                          <-Union 10 [CUSTOM_SIMPLE_EDGE]
+                                            <-Reducer 19 [CONTAINS]
+                                              Reduce Output Operator [RS_947]
+                                                Group By Operator [GBY_946] (rows=1 width=8)
+                                                  Output:["_col0"],aggregations:["count(_col0)"]
+                                                  Select Operator [SEL_945] (rows=1108786976 width=108)
                                                     Output:["_col0"]
-                                                    Merge Join Operator [MERGEJOIN_938] (rows=316788826 width=135)
-                                                      Conds:RS_1178._col0=RS_1184._col0(Inner),Output:["_col1"]
-                                                    <-Map 21 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1184]
-                                                        PartitionCols:_col0
-                                                        Select Operator [SEL_1181] (rows=8116 width=1119)
-                                                          Output:["_col0"]
-                                                          Filter Operator [FIL_1180] (rows=8116 width=1119)
-                                                            predicate:(d_date_sk is not null and d_year BETWEEN 1998 AND 2000)
-                                                            TableScan [TS_13] (rows=73049 width=1119)
-                                                              default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
-                                                    <-Map 17 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1178]
-                                                        PartitionCols:_col0
-                                                        Select Operator [SEL_1176] (rows=287989836 width=135)
-                                                          Output:["_col0","_col1"]
-                                                          Filter Operator [FIL_1175] (rows=287989836 width=135)
-                                                            predicate:cs_sold_date_sk is not null
-                                                            TableScan [TS_10] (rows=287989836 width=135)
-                                                              default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_quantity"]
-                                          <-Reducer 33 [CONTAINS]
-                                            Reduce Output Operator [RS_979]
-                                              Group By Operator [GBY_978] (rows=1 width=8)
-                                                Output:["_col0"],aggregations:["count(_col0)"]
-                                                Select Operator [SEL_977] (rows=1108786976 width=108)
-                                                  Output:["_col0"]
-                                                  Select Operator [SEL_975] (rows=158402938 width=135)
+                                                    Select Operator [SEL_943] (rows=316788826 width=135)
+                                                      Output:["_col0"]
+                                                      Merge Join Operator [MERGEJOIN_942] (rows=316788826 width=135)
+                                                        Conds:RS_1182._col0=RS_1188._col0(Inner),Output:["_col1"]
+                                                      <-Map 21 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1188]
+                                                          PartitionCols:_col0
+                                                          Select Operator [SEL_1185] (rows=8116 width=1119)
+                                                            Output:["_col0"]
+                                                            Filter Operator [FIL_1184] (rows=8116 width=1119)
+                                                              predicate:(d_date_sk is not null and d_year BETWEEN 1998 AND 2000)
+                                                              TableScan [TS_13] (rows=73049 width=1119)
+                                                                default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
+                                                      <-Map 17 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1182]
+                                                          PartitionCols:_col0
+                                                          Select Operator [SEL_1180] (rows=287989836 width=135)
+                                                            Output:["_col0","_col1"]
+                                                            Filter Operator [FIL_1179] (rows=287989836 width=135)
+                                                              predicate:cs_sold_date_sk is not null
+                                                              TableScan [TS_10] (rows=287989836 width=135)
+                                                                default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_quantity"]
+                                            <-Reducer 33 [CONTAINS]
+                                              Reduce Output Operator [RS_983]
+                                                Group By Operator [GBY_982] (rows=1 width=8)
+                                                  Output:["_col0"],aggregations:["count(_col0)"]
+                                                  Select Operator [SEL_981] (rows=1108786976 width=108)
                                                     Output:["_col0"]
-                                                    Merge Join Operator [MERGEJOIN_974] (rows=158402938 width=135)
-                                                      Conds:RS_1196._col0=RS_1202._col0(Inner),Output:["_col1"]
-                                                    <-Map 35 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1202]
-                                                        PartitionCols:_col0
-                                                        Select Operator [SEL_1199] (rows=8116 width=1119)
-                                                          Output:["_col0"]
-                                                          Filter Operator [FIL_1198] (rows=8116 width=1119)
-                                                            predicate:(d_date_sk is not null and d_year BETWEEN 1998 AND 2000)
-                                                            TableScan [TS_24] (rows=73049 width=1119)
-                                                              default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
-                                                    <-Map 31 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1196]
-                                                        PartitionCols:_col0
-                                                        Select Operator [SEL_1194] (rows=144002668 width=135)
-                                                          Output:["_col0","_col1"]
-                                                          Filter Operator [FIL_1193] (rows=144002668 width=135)
-                                                            predicate:ws_sold_date_sk is not null
-                                                            TableScan [TS_21] (rows=144002668 width=135)
-                                                              default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_quantity"]
-                                          <-Reducer 9 [CONTAINS]
-                                            Reduce Output Operator [RS_913]
-                                              Group By Operator [GBY_912] (rows=1 width=8)
-                                                Output:["_col0"],aggregations:["count(_col0)"]
-                                                Select Operator [SEL_911] (rows=1108786976 width=108)
-                                                  Output:["_col0"]
-                                                  Select Operator [SEL_909] (rows=633595212 width=88)
+                                                    Select Operator [SEL_979] (rows=158402938 width=135)
+                                                      Output:["_col0"]
+                                                      Merge Join Operator [MERGEJOIN_978] (rows=158402938 width=135)
+                                                        Conds:RS_1200._col0=RS_1206._col0(Inner),Output:["_col1"]
+                                                      <-Map 35 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1206]
+                                                          PartitionCols:_col0
+                                                          Select Operator [SEL_1203] (rows=8116 width=1119)
+                                                            Output:["_col0"]
+                                                            Filter Operator [FIL_1202] (rows=8116 width=1119)
+                                                              predicate:(d_date_sk is not null and d_year BETWEEN 1998 AND 2000)
+                                                              TableScan [TS_24] (rows=73049 width=1119)
+                                                                default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
+                                                      <-Map 31 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1200]
+                                                          PartitionCols:_col0
+                                                          Select Operator [SEL_1198] (rows=144002668 width=135)
+                                                            Output:["_col0","_col1"]
+                                                            Filter Operator [FIL_1197] (rows=144002668 width=135)
+                                                              predicate:ws_sold_date_sk is not null
+                                                              TableScan [TS_21] (rows=144002668 width=135)
+                                                                default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_quantity"]
+                                            <-Reducer 9 [CONTAINS]
+                                              Reduce Output Operator [RS_915]
+                                                Group By Operator [GBY_914] (rows=1 width=8)
+                                                  Output:["_col0"],aggregations:["count(_col0)"]
+                                                  Select Operator [SEL_913] (rows=1108786976 width=108)
                                                     Output:["_col0"]
-                                                    Merge Join Operator [MERGEJOIN_908] (rows=633595212 width=88)
-                                                      Conds:RS_1061._col0=RS_1070._col0(Inner),Output:["_col1"]
-                                                    <-Map 86 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1070]
-                                                        PartitionCols:_col0
-                                                        Select Operator [SEL_1064] (rows=8116 width=1119)
-                                                          Output:["_col0"]
-                                                          Filter Operator [FIL_1063] (rows=8116 width=1119)
-                                                            predicate:(d_date_sk is not null and d_year BETWEEN 1999 AND 2001)
-                                                            TableScan [TS_97] (rows=73049 width=1119)
-                                                              default@date_dim,d1,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
-                                                    <-Map 1 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1061]
-                                                        PartitionCols:_col0
-                                                        Select Operator [SEL_1059] (rows=575995635 width=88)
-                                                          Output:["_col0","_col1"]
-                                                          Filter Operator [FIL_1058] (rows=575995635 width=88)
-                                                            predicate:ss_sold_date_sk is not null
-                                                            TableScan [TS_0] (rows=575995635 width=88)
-                                                              default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_quantity"]
-                            <-Reducer 27 [CUSTOM_SIMPLE_EDGE] vectorized
-                              PARTITION_ONLY_SHUFFLE [RS_1143]
-                                Select Operator [SEL_1142] (rows=1 width=120)
-                                  Output:["_col0"]
-                                  Group By Operator [GBY_1141] (rows=1 width=120)
-                                    Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"]
-                                  <-Union 26 [CUSTOM_SIMPLE_EDGE]
-                                    <-Reducer 25 [CONTAINS]
-                                      Reduce Output Operator [RS_961]
-                                        Group By Operator [GBY_960] (rows=1 width=120)
-                                          Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"]
-                                          Select Operator [SEL_959] (rows=1108786976 width=108)
-                                            Output:["_col0"]
-                                            Select Operator [SEL_957] (rows=316788826 width=135)
-                                              Output:["_col0","_col1"]
-                                              Merge Join Operator [MERGEJOIN_956] (rows=316788826 width=135)
-                                                Conds:RS_1191._col0=RS_1185._col0(Inner),Output:["_col1","_col2"]
-                                              <-Map 21 [SIMPLE_EDGE] vectorized
-                                                SHUFFLE [RS_1185]
+                                                    Select Operator [SEL_911] (rows=633595212 width=88)
+                                                      Output:["_col0"]
+                                                      Merge Join Operator [MERGEJOIN_910] (rows=633595212 width=88)
+                                                        Conds:RS_1065._col0=RS_1074._col0(Inner),Output:["_col1"]
+                                                      <-Map 86 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1074]
+                                                          PartitionCols:_col0
+                                                          Select Operator [SEL_1068] (rows=8116 width=1119)
+                                                            Output:["_col0"]
+                                                            Filter Operator [FIL_1067] (rows=8116 width=1119)
+                                                              predicate:(d_date_sk is not null and d_year BETWEEN 1999 AND 2001)
+                                                              TableScan [TS_97] (rows=73049 width=1119)
+                                                                default@date_dim,d1,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
+                                                      <-Map 1 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1065]
+                                                          PartitionCols:_col0
+                                                          Select Operator [SEL_1063] (rows=575995635 width=88)
+                                                            Output:["_col0","_col1"]
+                                                            Filter Operator [FIL_1062] (rows=575995635 width=88)
+                                                              predicate:ss_sold_date_sk is not null
+                                                              TableScan [TS_0] (rows=575995635 width=88)
+                                                                default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_quantity"]
+                              <-Reducer 27 [CUSTOM_SIMPLE_EDGE] vectorized
+                                PARTITION_ONLY_SHUFFLE [RS_1147]
+                                  Select Operator [SEL_1146] (rows=1 width=120)
+                                    Output:["_col0"]
+                                    Group By Operator [GBY_1145] (rows=1 width=120)
+                                      Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"]
+                                    <-Union 26 [CUSTOM_SIMPLE_EDGE]
+                                      <-Reducer 25 [CONTAINS]
+                                        Reduce Output Operator [RS_965]
+                                          Group By Operator [GBY_964] (rows=1 width=120)
+                                            Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"]
+                                            Select Operator [SEL_963] (rows=1108786976 width=108)
+                                              Output:["_col0"]
+                                              Select Operator [SEL_961] (rows=316788826 width=135)
+                                                Output:["_col0","_col1"]
+                                                Merge Join Operator [MERGEJOIN_960] (rows=316788826 width=135)
+                                                  Conds:RS_1195._col0=RS_1189._col0(Inner),Output:["_col1","_col2"]
+                                                <-Map 21 [SIMPLE_EDGE] vectorized
+                                                  SHUFFLE [RS_1189]
+                                                    PartitionCols:_col0
+                                                     Please refer to the previous Select Operator [SEL_1185]
+                                                <-Map 43 [SIMPLE_EDGE] vectorized
+                                                  SHUFFLE [RS_1195]
+                                                    PartitionCols:_col0
+                                                    Select Operator [SEL_1193] (rows=287989836 width=135)
+                                                      Output:["_col0","_col1","_col2"]
+                                                      Filter Operator [FIL_1192] (rows=287989836 width=135)
+                                                        predicate:cs_sold_date_sk is not null
+                                                        TableScan [TS_55] (rows=287989836 width=135)
+                                                          default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_quantity","cs_list_price"]
+                                      <-Reducer 37 [CONTAINS]
+                                        Reduce Output Operator [RS_1001]
+                                          Group By Operator [GBY_1000] (rows=1 width=120)
+                                            Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"]
+                                            Select Operator [SEL_999] (rows=1108786976 width=108)
+                                              Output:["_col0"]
+                                              Select Operator [SEL_997] (rows=158402938 width=135)
+                                                Output:["_col0","_col1"]
+                                                Merge Join Operator [MERGEJOIN_996] (rows=158402938 width=135)
+                                                  Conds:RS_1213._col0=RS_1207._col0(Inner),Output:["_col1","_col2"]
+                                                <-Map 35 [SIMPLE_EDGE] vectorized
+                                                  SHUFFLE [RS_1207]
+                                                    PartitionCols:_col0
+                                                     Please refer to the previous Select Operator [SEL_1203]
+                                                <-Map 44 [SIMPLE_EDGE] vectorized
+                                                  SHUFFLE [RS_1213]
+                                                    PartitionCols:_col0
+                                                    Select Operator [SEL_1211] (rows=144002668 width=135)
+                                                      Output:["_col0","_col1","_col2"]
+                                                      Filter Operator [FIL_1210] (rows=144002668 width=135)
+                                                        predicate:ws_sold_date_sk is not null
+                                                        TableScan [TS_66] (rows=144002668 width=135)
+                                                          default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_quantity","ws_list_price"]
+                                      <-Reducer 41 [CONTAINS]
+                                        Reduce Output Operator [RS_1019]
+                                          Group By Operator [GBY_1018] (rows=1 width=120)
+                                            Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"]
+                                            Select Operator [SEL_1017] (rows=1108786976 width=108)
+                                              Output:["_col0"]
+                                              Select Operator [SEL_1015] (rows=633595212 width=88)
+                                                Output:["_col0","_col1"]
+                                                Merge Join Operator [MERGEJOIN_1014] (rows=633595212 width=88)
+                                                  Conds:RS_1218._col0=RS_1075._col0(Inner),Output:["_col1","_col2"]
+                                                <-Map 86 [SIMPLE_EDGE] vectorized
+                                                  SHUFFLE [RS_1075]
+                                                    PartitionCols:_col0
+                                                     Please refer to the previous Select Operator [SEL_1068]
+                                                <-Map 39 [SIMPLE_EDGE] vectorized
+                                                  SHUFFLE [RS_1218]
+                                                    PartitionCols:_col0
+                                                    Select Operator [SEL_1216] (rows=575995635 width=88)
+                                                      Output:["_col0","_col1","_col2"]
+                                                      Filter Operator [FIL_1215] (rows=575995635 width=88)
+                                                        predicate:ss_sold_date_sk is not null
+                                                        TableScan [TS_45] (rows=575995635 width=88)
+                                                          default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_quantity","ss_list_price"]
+                              <-Reducer 52 [CUSTOM_SIMPLE_EDGE] vectorized
+                                PARTITION_ONLY_SHUFFLE [RS_1158]
+                                  Group By Operator [GBY_1157] (rows=348467716 width=135)
+                                    Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                  <-Reducer 51 [SIMPLE_EDGE]
+                                    SHUFFLE [RS_369]
+                                      PartitionCols:_col0, _col1, _col2
+                                      Group By Operator [GBY_368] (rows=696935432 width=135)
+                                        Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col3)","count()"],keys:_col0, _col1, _col2
+                                        Select Operator [SEL_366] (rows=696935432 width=135)
+                                          Output:["_col0","_col1","_col2","_col3"]
+                                          Merge Join Operator [MERGEJOIN_878] (rows=696935432 width=135)
+                                            Conds:RS_362._col1=RS_1122._col0(Inner),RS_362._col1=RS_1156._col0(Inner),Output:["_col2","_col3","_col8","_col9","_col10"]
+                                          <-Map 56 [SIMPLE_EDGE] vectorized
+                                            SHUFFLE [RS_1122]
+                                              PartitionCols:_col0
+                                              Select Operator [SEL_1110] (rows=462000 width=1436)
+                                                Output:["_col0","_col1","_col2","_col3"]
+                                                Filter Operator [FIL_1101] (rows=462000 width=1436)
+                                                  predicate:i_item_sk is not null
+                                                  TableScan [TS_91] (rows=462000 width=1436)
+                                                    default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_brand_id","i_class_id","i_category_id"]
+                                          <-Reducer 50 [SIMPLE_EDGE]
+                                            SHUFFLE [RS_362]
+                                              PartitionCols:_col1
+                                              Merge Join Operator [MERGEJOIN_870] (rows=316788826 width=135)
+                                                Conds:RS_1150._col0=RS_1093._col0(Inner),Output:["_col1","_col2","_col3"]
+                                              <-Map 49 [SIMPLE_EDGE] vectorized
+                                                SHUFFLE [RS_1093]
                                                   PartitionCols:_col0
-                                                   Please refer to the previous Select Operator [SEL_1181]
-                                              <-Map 43 [SIMPLE_EDGE] vectorized
-                                                SHUFFLE [RS_1191]
-                                                  PartitionCols:_col0
-                                                  Select Operator [SEL_1189] (rows=287989836 width=135)
-                                                    Output:["_col0","_col1","_col2"]
-                                                    Filter Operator [FIL_1188] (rows=287989836 width=135)
-                                                      predicate:cs_sold_date_sk is not null
-                                                      TableScan [TS_55] (rows=287989836 width=135)
-                                                        default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_quantity","cs_list_price"]
-                                    <-Reducer 37 [CONTAINS]
-                                      Reduce Output Operator [RS_997]
-                                        Group By Operator [GBY_996] (rows=1 width=120)
-                                          Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"]
-                                          Select Operator [SEL_995] (rows=1108786976 width=108)
-                                            Output:["_col0"]
-                                            Select Operator [SEL_993] (rows=158402938 width=135)
-                                              Output:["_col0","_col1"]
-                                              Merge Join Operator [MERGEJOIN_992] (rows=158402938 width=135)
-                                                Conds:RS_1209._col0=RS_1203._col0(Inner),Output:["_col1","_col2"]
-                                              <-Map 35 [SIMPLE_EDGE] vectorized
-                                                SHUFFLE [RS_1203]
-                                                  PartitionCols:_col0
-                                                   Please refer to the previous Select Operator [SEL_1199]
-                                              <-Map 44 [SIMPLE_EDGE] vectorized
-                                                SHUFFLE [RS_1209]
-                                                  PartitionCols:_col0
-                                                  Select Operator [SEL_1207] (rows=144002668 width=135)
-                                                    Output:["_col0","_col1","_col2"]
-                                                    Filter Operator [FIL_1206] (rows=144002668 width=135)
-                                                      predicate:ws_sold_date_sk is not null
-                                                      TableScan [TS_66] (rows=144002668 width=135)
-                                                        default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_quantity","ws_list_price"]
-                                    <-Reducer 41 [CONTAINS]
-                                      Reduce Output Operator [RS_1015]
-                                        Group By Operator [GBY_1014] (rows=1 width=120)
-                                          Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"]
-                                          Select Operator [SEL_1013] (rows=1108786976 width=108)
-                                            Output:["_col0"]
-                                            Select Operator [SEL_1011] (rows=633595212 width=88)
-                                              Output:["_col0","_col1"]
-                                              Merge Join Operator [MERGEJOIN_1010] (rows=633595212 width=88)
-                                                Conds:RS_1214._col0=RS_1071._col0(Inner),Output:["_col1","_col2"]
-                                              <-Map 86 [SIMPLE_EDGE] vectorized
-                                                SHUFFLE [RS_1071]
+                                                  Select Operator [SEL_1091] (rows=18262 width=1119)
+                                                    Output:["_col0"]
+                                                    Filter Operator [FIL_1090] (rows=18262 width=1119)
+                                                      predicate:((d_moy = 11) and (d_year = 2000) and d_date_sk is not null)
+                                                      TableScan [TS_85] (rows=73049 width=1119)
+                                                        default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
+                                              <-Map 91 [SIMPLE_EDGE] vectorized
+                                                SHUFFLE [RS_1150]
                                                   PartitionCols:_col0
-                                                   Please refer to the previous Select Operator [SEL_1064]
-                                              <-Map 39 [SIMPLE_EDGE] vectorized
-                                                SHUFFLE [RS_1214]
+                                                  Select Operator [SEL_1149] (rows=287989836 width=135)
+                                                    Output:["_col0","_col1","_col2","_col3"]
+                                                    Filter Operator [FIL_1148] (rows=287989836 width=135)
+                                                      predicate:(cs_item_sk is not null and cs_sold_date_sk is not null)
+                                                      TableScan [TS_271] (rows=287989836 width=135)
+                                                        default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk","cs_quantity","cs_list_price"]
+                                          <-Reducer 68 [ONE_TO_ONE_EDGE] vectorized
+                                            FORWARD [RS_1156]
+                                              PartitionCols:_col0
+                                              Group By Operator [GBY_1155] (rows=254100 width=1436)
+                                                Output:["_col0"],keys:KEY._col0
+                                              <-Reducer 67 [SIMPLE_EDGE]
+                                                SHUFFLE [RS_356]
                                                   PartitionCols:_col0
-                                                  Select Operator [SEL_1212] (rows=575995635 width=88)
-                                                    Output:["_col0","_col1","_col2"]
-                                                    Filter Operator [FIL_1211] (rows=575995635 width=88)
-                                                      predicate:ss_sold_date_sk is not null
-                                                      TableScan [TS_45] (rows=575995635 width=88)
-                                                        default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_quantity","ss_list_price"]
-                            <-Reducer 52 [CUSTOM_SIMPLE_EDGE] vectorized
-                              PARTITION_ONLY_SHUFFLE [RS_1154]
-                                Group By Operator [GBY_1153] (rows=348467716 width=135)
-                                  Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"],keys:KEY._col0, KEY._col1, KEY._col2
-                                <-Reducer 51 [SIMPLE_EDGE]
-                                  SHUFFLE [RS_369]
-                                    PartitionCols:_col0, _col1, _col2
-                                    Group By Operator [GBY_368] (rows=696935432 width=135)
-                                      Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col3)","count()"],keys:_col0, _col1, _col2
-                                      Select Operator [SEL_366] (rows=696935432 width=135)
-                                        Output:["_col0","_col1","_col2","_col3"]
-                                        Merge Join Operator [MERGEJOIN_877] (rows=696935432 width=135)
-                                          Conds:RS_362._col1=RS_1118._col0(Inner),RS_362._col1=RS_1152._col0(Inner),Output:["_col2","_col3","_col8","_col9","_col10"]
-                                        <-Map 56 [SIMPLE_EDGE] vectorized
-                                          SHUFFLE [RS_1118]
-                                            PartitionCols:_col0
-                                            Select Operator [SEL_1106] (rows=462000 width=1436)
-                                              Output:["_col0","_col1","_col2","_col3"]
-                                              Filter Operator [FIL_1097] (rows=462000 width=1436)
-                                                predicate:i_item_sk is not null
-                                                TableScan [TS_91] (rows=462000 width=1436)
-                                                  default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_brand_id","i_class_id","i_category_id"]
-                                        <-Reducer 50 [SIMPLE_EDGE]
-                                          SHUFFLE [RS_362]
-                                            PartitionCols:_col1
-                                            Merge Join Operator [MERGEJOIN_869] (rows=316788826 width=135)
-                                              Conds:RS_1146._col0=RS_1089._col0(Inner),Output:["_col1","_col2","_col3"]
-                                            <-Map 49 [SIMPLE_EDGE] vectorized
-                                              SHUFFLE [RS_1089]
-                                                PartitionCols:_col0
-                                                Select Operator [SEL_1087] (rows=18262 width=1119)
-                                                  Output:["_col0"]
-                                                  Filter Operator [FIL_1086] (rows=18262 width=1119)
-                                                    predicate:((d_moy = 11) and (d_year = 2000) and d_date_sk is not null)
-                                                    TableScan [TS_85] (rows=73049 width=1119)
-                                                      default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
-                                            <-Map 91 [SIMPLE_EDGE] vectorized
-                                              SHUFFLE [RS_1146]
-                                                PartitionCols:_col0
-                                                Select Operator [SEL_1145] (rows=287989836 width=135)
-                                                  Output:["_col0","_col1","_col2","_col3"]
-                                                  Filter Operator [FIL_1144] (rows=287989836 width=135)
-                                                    predicate:(cs_item_sk is not null and cs_sold_date_sk is not null)
-                                                    TableScan [TS_271] (rows=287989836 width=135)
-                                                      default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk","cs_quantity","cs_list_price"]
-                                        <-Reducer 68 [ONE_TO_ONE_EDGE] vectorized
-                                          FORWARD [RS_1152]
-                                            PartitionCols:_col0
-                                            Group By Operator [GBY_1151] (rows=254100 width=1436)
-                                              Output:["_col0"],keys:KEY._col0
-                                            <-Reducer 67 [SIMPLE_EDGE]
-                                              SHUFFLE [RS_356]
-                                                PartitionCols:_col0
-                                                Group By Operator [GBY_355] (rows=508200 width=1436)
-                                                  Output:["_col0"],keys:_col0
-                                                  Merge Join Operator [MERGEJOIN_876] (rows=508200 width=1436)
-                                                    Conds:RS_1114._col1, _col2, _col3=RS_1150._col0, _col1, _col2(Inner),Output:["_col0"]
-                                                  <-Map 56 [SIMPLE_EDGE] vectorized
-                                                    SHUFFLE [RS_1114]
-                                                      PartitionCols:_col1, _col2, _col3
-                                                      Select Operator [SEL_1102] (rows=462000 width=1436)
-                                                        Output:["_col0","_col1","_col2","_col3"]
-                                                        Filter Operator [FIL_1093] (rows=462000 width=1436)
-                                                          predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
-                                                           Please refer to the previous TableScan [TS_91]
-                                                  <-Reducer 72 [ONE_TO_ONE_EDGE] vectorized
-                                                    FORWARD [RS_1150]
-                                                      PartitionCols:_col0, _col1, _col2
-                                                      Select Operator [SEL_1149] (rows=1 width=108)
-                                                        Output:["_col0","_col1","_col2"]
-                                                        Filter Operator [FIL_1148] (rows=1 width=108)
-                                                          predicate:(_col3 = 3L)
-                                                          Group By Operator [GBY_1147] (rows=304916424 width=108)
-                                                            Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
-                                                          <-Union 71 [SIMPLE_EDGE]
-                                                            <-Reducer 70 [CONTAINS] vectorized
-                                                              Reduce Output Operator [RS_1236]
-                                                                PartitionCols:_col0, _col1, _col2
-                                                                Group By Operator [GBY_1235] (rows=609832849 width=108)
-                                                                  Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2
-                                                                  Group By Operator [GBY_1234] (rows=348477374 width=88)
-                                                                    Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
-                                                                  <-Reducer 69 [SIMPLE_EDGE]
-                                                                    SHUFFLE [RS_300]
-                                                                      PartitionCols:_col0, _col1, _col2
-                                                                      Group By Operator [GBY_299] (rows=696954748 width=88)
-                                                                        Output:["_col0","_col1","_col2","_col3"],aggregations:["count()"],keys:_col5, _col6, _col7
-                                                                        Merge Join Operator [MERGEJOIN_871] (rows=696954748 width=88)
-                                                                          Conds:RS_295._col1=RS_1115._col0(Inner),Output:["_col5","_col6","_col7"]
-                                                                        <-Map 56 [SIMPLE_EDGE] vectorized
-                                                                          SHUFFLE [RS_1115]
-                                                                            PartitionCols:_col0
-                                                                            Select Operator [SEL_1103] (rows=462000 width=1436)
-                                                                              Output:["_col0","_col1","_col2","_col3"]
-                                                                              Filter Operator [FIL_1094] (rows=462000 width=1436)
-                                                                                predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
-                                                                                 Please refer to the previous TableScan [TS_91]
-                                                                        <-Reducer 85 [SIMPLE_EDGE]
-                                                                          SHUFFLE [RS_295]
-                                                                            PartitionCols:_col1
-                                                                            Merge Join Operator [MERGEJOIN_855] (rows=633595212 width=88)
-                                                                              Conds:RS_1218._col0=RS_1065._col0(Inner),Output:["_col1"]
-                                                                            <-Map 86 [SIMPLE_EDGE] vectorized
-                                                                              SHUFFLE [RS_1065]
-                                                                                PartitionCols:_col0
-                                                                                 Please refer to the previous Select Operator [SEL_1064]
-                                                                            <-Map 84 [SIMPLE_EDGE] vectorized
-                                                                              SHUFFLE [RS_1218]
-                                                                                PartitionCols:_col0
-                                                                                Select Operator [SEL_1217] (rows=575995635 width=88)
-                                                                                  Output:["_col0","_col1"]
-                                                                                  Filter Operator [FIL_1216] (rows=575995635 width=88)
-                                                                                    predicate:(ss_item_sk is not null and ss_sold_date_sk is not null)
-                                                                                    TableScan [TS_94] (rows=575995635 width=88)
-                                                                                      default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk"]
-                                                            <-Reducer 79 [CONTAINS] vectorized
-                                                              Reduce Output Operator [RS_1242]
-                                                                PartitionCols:_col0, _col1, _col2
-                                                                Group By Operator [GBY_1241] (rows=609832849 width=108)
-                                                                  Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2
-                                                                  Group By Operator [GBY_1240] (rows=174233858 width=135)
-                                                                    Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
-                                                                  <-Reducer 78 [SIMPLE_EDGE]
-                                                                    SHUFFLE [RS_320]
-                                                                      PartitionCols:_col0, _col1, _col2
-                                                                      Group By Operator [GBY_319] (rows=348467716 width=135)
-                                                                        Output:["_col0","_col1","_col2","_col3"],aggregations:["count()"],keys:_col5, _col6, _col7
-                                                                        Merge Join Operator [MERGEJOIN_873] (rows=348467716 width=135)
-                                                                          Conds:RS_315._col1=RS_1116._col0(Inner),Output:["_col5","_col6","_col7"]
-                                                                        <-Map 56 [SIMPLE_EDGE] vectorized
-                                                                          SHUFFLE [RS_1116]
-                                                                            PartitionCols:_col0
-                                                                            Select Operator [SEL_1104] (rows=462000 width=1436)
-                                                                              Output:["_col0","_col1","_col2","_col3"]
-                                                                              Filter Operator [FIL_1095] (rows=462000 width=1436)
-                                                                                predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
-                                                                                 Please refer to the previous TableScan [TS_91]
-                                                                        <-Reducer 87 [SIMPLE_EDGE]
-                                                                          SHUFFLE [RS_315]
-                                                                            PartitionCols:_col1
-                                                                            Merge Join Operator [MERGEJOIN_857] (rows=316788826 width=135)
-                                                                              Conds:RS_1224._col0=RS_1066._col0(Inner),Output:["_col1"]
-                                                                            <-Map 86 [SIMPLE_EDGE] vectorized
-                                                                              SHUFFLE [RS_1066]
-                                                                                PartitionCols:_col0
-                                                                                 Please refer to the previous Select Operator [SEL_1064]
-                                                                            <-Map 89 [SIMPLE_EDGE] vectorized
-                                                                              SHUFFLE [RS_1224]
-                                                                                PartitionCols:_col0
-                                                                                Select Operator [SEL_1223] (rows=287989836 width=135)
-                                                                                  Output:["_col0","_col1"]
-                                                                                  Filter Operator [FIL_1222] (rows=287989836 width=135)
-                                                                                    predicate:(cs_item_sk is not null and cs_sold_date_sk is not null)
-                                                                                    TableScan [TS_114] (rows=287989836 width=135)
-                                                                                      default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk"]
-                                                            <-Reducer 82 [CONTAINS] vectorized
-                                                              Reduce Output Operator [RS_1248]
-                                                                PartitionCols:_col0, _col1, _col2
-                                                                Group By Operator [GBY_1247] (rows=609832849 width=108)
-                                                                  Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2
-                                                                  Group By Operator [GBY_1246] (rows=87121617 width=135)
-                                                                    Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
-                                                                  <-Reducer 81 [SIMPLE_EDGE]
-                                                                    SHUFFLE [RS_341]
-                                                                      PartitionCols:_col0, _col1, _col2
-                                                                      Group By Operator [GBY_340] (rows=174243235 width=135)
-                                                                        Output:["_col0","_col1","_col2","_col3"],aggregations:["count()"],keys:_col5, _col6, _col7
-                                                                        Merge Join Operator [MERGEJOIN_875] (rows=174243235 width=135)
-                                                                          Conds:RS_336._col1=RS_1117._col0(Inner),Output:["_col5","_col6","_col7"]
-                                                                        <-Map 56 [SIMPLE_EDGE] vectorized
-                                                                          SHUFFLE [RS_1117]
-                                                                            PartitionCols:_col0
-                                                                            Select Operator [SEL_1105] (rows=462000 width=1436)
-                                                                              Output:["_col0","_col1","_col2","_col3"]
-                                                                              Filter Operator [FIL_1096] (rows=462000 width=1436)
-                                                                                predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
-                                                                                 Please refer to the previous TableScan [TS_91]
-                                                                        <-Reducer 88 [SIMPLE_EDGE]
-                                                                          SHUFFLE [RS_336]
-                                                                            PartitionCols:_col1
-                                                                            Merge Join Operator [MERGEJOIN_859] (rows=158402938 width=135)
-                                                                              Conds:RS_1230._col0=RS_1067._col0(Inner),Output:["_col1"]
-                                                                            <-Map 86 [SIMPLE_EDGE] vectorized
-                                                                              SHUFFLE [RS_1067]
-                                                                                PartitionCols:_col0
-                                                                                 Please refer to the previous Select Operator [SEL_1064]
-                                                                            <-Map 90 [SIMPLE_EDGE] vectorized
-                                                                              SHUFFLE [RS_1230]
-                                                                                PartitionCols:_col0
-                                                                                Select Operator [SEL_1229] (rows=144002668 width=135)
-                                                                                  Output:["_col0","_col1"]
-                                                                                  Filter Operator [FIL_1228] (rows=144002668 width=135)
-                                                                                    predicate:(ws_item_sk is not null and ws_sold_date_sk is not null)
-                                                                                    TableScan [TS_135] (rows=144002668 width=135)
-                                                                                      default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk"]
+                                                  Group By Operator [GBY_355] (rows=508200 width=1436)
+                                                    Output:["_col0"],keys:_col0
+                                                    Merge Join Operator [MERGEJOIN_877] (rows=508200 width=1436)
+                                                      Conds:RS_1118._col1, _col2, _col3=RS_1154._col0, _col1, _col2(Inner),Output:["_col0"]
+                                                    <-Map 56 [SIMPLE_EDGE] vectorized
+                                                      SHUFFLE [RS_1118]
+                                                        PartitionCols:_col1, _col2, _col3
+                                                        Select Operator [SEL_1106] (rows=462000 width=1436)
+                                                          Output:["_col0","_col1","_col2","_col3"]
+                                                          Filter Operator [FIL_1097] (rows=462000 width=1436)
+                                                            predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
+                                                             Please refer to the previous TableScan [TS_91]
+                                                    <-Reducer 72 [ONE_TO_ONE_EDGE] vectorized
+                                                      FORWARD [RS_1154]
+                                                        PartitionCols:_col0, _col1, _col2
+                                                        Select Operator [SEL_1153] (rows=1 width=108)
+                                                          Output:["_col0","_col1","_col2"]
+                                                          Filter Operator [FIL_1152] (rows=1 width=108)
+                                                            predicate:(_col3 = 3L)
+                                                            Group By Operator [GBY_1151] (rows=304916424 width=108)
+                                                              Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                                            <-Union 71 [SIMPLE_EDGE]
+                                                              <-Reducer 70 [CONTAINS] vectorized
+                                                                Reduce Output Operator [RS_1240]
+                                                                  PartitionCols:_col0, _col1, _col2
+                                                                  Group By Operator [GBY_1239] (rows=609832849 width=108)
+                                                                    Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2
+                                                                    Group By Operator [GBY_1238] (rows=348477374 width=88)
+                                                                      Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                                                    <-Reducer 69 [SIMPLE_EDGE]
+                                                                      SHUFFLE [RS_300]
+                                                                        PartitionCols:_col0, _col1, _col2
+                                                                        Group By Operator [GBY_299] (rows=696954748 width=88)
+                                                                          Output:["_col0","_col1","_col2","_col3"],aggregations:["count()"],keys:_col5, _col6, _col7
+                                                                          Merge Join Operator [MERGEJOIN_872] (rows=696954748 width=88)
+                                                                            Conds:RS_295._col1=RS_1119._col0(Inner),Output:["_col5","_col6","_col7"]
+                                                                          <-Map 56 [SIMPLE_EDGE] vectorized
+                                                                            SHUFFLE [RS_1119]
+                                                                              PartitionCols:_col0
+                                                                              Select Operator [SEL_1107] (rows=462000 width=1436)
+                                                                                Output:["_col0","_col1","_col2","_col3"]
+                                                                                Filter Operator [FIL_1098] (rows=462000 width=1436)
+                                                                                  predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
+                                                                                   Please refer to the previous TableScan [TS_91]
+                                                                          <-Reducer 85 [SIMPLE_EDGE]
+                                                                            SHUFFLE [RS_295]
+                                                                              PartitionCols:_col1
+                                                                              Merge Join Operator [MERGEJOIN_856] (rows=633595212 width=88)
+                                                                                Conds:RS_1222._col0=RS_1069._col0(Inner),Output:["_col1"]
+                                                                              <-Map 86 [SIMPLE_EDGE] vectorized
+                                                                                SHUFFLE [RS_1069]
+                                                                                  PartitionCols:_col0
+                                                                                   Please refer to the previous Select Operator [SEL_1068]
+                                                                              <-Map 84 [SIMPLE_EDGE] vectorized
+                                                                                SHUFFLE [RS_1222]
+                                                                                  PartitionCols:_col0
+                                                                                  Select Operator [SEL_1221] (rows=575995635 width=88)
+                                                                                    Output:["_col0","_col1"]
+                                                                                    Filter Operator [FIL_1220] (rows=575995635 width=88)
+                                                                                      predicate:(ss_item_sk is not null and ss_sold_date_sk is not null)
+                                                                                      TableScan [TS_94] (rows=575995635 width=88)
+                                                                                        default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk"]
+                                                              <-Reducer 79 [CONTAINS] vectorized
+                                                                Reduce Output Operator [RS_1246]
+                                                                  PartitionCols:_col0, _col1, _col2
+                                                                  Group By Operator [GBY_1245] (rows=609832849 width=108)
+                                                                    Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2
+                                                                    Group By Operator [GBY_1244] (rows=174233858 width=135)
+                                                                      Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                                                    <-Reducer 78 [SIMPLE_EDGE]
+                                                                      SHUFFLE [RS_320]
+                                                                        PartitionCols:_col0, _col1, _col2
+                                                                        Group By Operator [GBY_319] (rows=348467716 width=135)
+                                                                          Output:["_col0","_col1","_col2","_col3"],aggregations:["count()"],keys:_col5, _col6, _col7
+                                                                          Merge Join Operator [MERGEJOIN_874] (rows=348467716 width=135)
+                                                                            Conds:RS_315._col1=RS_1120._col0(Inner),Output:["_col5","_col6","_col7"]
+                                                                          <-Map 56 [SIMPLE_EDGE] vectorized
+                                                                            SHUFFLE [RS_1120]
+                                                                              PartitionCols:_col0
+                                                                              Select Operator [SEL_1108] (rows=462000 width=1436)
+                                                                                Output:["_col0","_col1","_col2","_col3"]
+                                                                                Filter Operator [FIL_1099] (rows=462000 width=1436)
+                                                                                  predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
+                                                                                   Please refer to the previous TableScan [TS_91]
+                                                                          <-Reducer 87 [SIMPLE_EDGE]
+                                                                            SHUFFLE [RS_315]
+                                                                              PartitionCols:_col1
+                                                                              Merge Join Operator [MERGEJOIN_858] (rows=316788826 width=135)
+                                                                                Conds:RS_1228._col0=RS_1070._col0(Inner),Output:["_col1"]
+                                                                              <-Map 86 [SIMPLE_EDGE] vectorized
+                                                                                SHUFFLE [RS_1070]
+                                                                                  PartitionCols:_col0
+                                                                                   Please refer to the previous Select Operator [SEL_1068]
+                                                                              <-Map 89 [SIMPLE_EDGE] vectorized
+                                                                                SHUFFLE [RS_1228]
+                                                                                  PartitionCols:_col0
+                                                                                  Select Operator [SEL_1227] (rows=287989836 width=135)
+                                                                                    Output:["_col0","_col1"]
+                                                                                    Filter Operator [FIL_1226] (rows=287989836 width=135)
+                                                                                      predicate:(cs_item_sk is not null and cs_sold_date_sk is not null)
+                                                                                      TableScan [TS_114] (rows=287989836 width=135)
+                                                                                        default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk"]
+                                                              <-Reducer 82 [CONTAINS] vectorized
+                                                                Reduce Output Operator [RS_1252]
+                                                                  PartitionCols:_col0, _col1, _col2
+                                                                  Group By Operator [GBY_1251] (rows=609832849 width=108)
+                                                                    Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2
+                                                                    Group By Operator [GBY_1250] (rows=87121617 width=135)
+                                                                      Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                                                    <-Reducer 81 [SIMPLE_EDGE]
+                                                                      SHUFFLE [RS_341]
+                                                                        PartitionCols:_col0, _col1, _col2
+                                                                        Group By Operator [GBY_340] (rows=174243235 width=135)
+                                                                          Output:["_col0","_col1","_col2","_col3"],aggregations:["count()"],keys:_col5, _col6, _col7
+                                                                          Merge Join Operator [MERGEJOIN_876] (rows=174243235 width=135)
+                                                                            Conds:RS_336._col1=RS_1121._col0(Inner),Output:["_col5","_col6","_col7"]
+                                                                          <-Map 56 [SIMPLE_EDGE] vectorized
+                                                                            SHUFFLE [RS_1121]
+                                                                              PartitionCols:_col0
+                                                                              Select Operator [SEL_1109] (rows=462000 width=1436)
+                                                                                Output:["_col0","_col1","_col2","_col3"]
+                                                                                Filter Operator [FIL_1100] (rows=462000 width=1436)
+                                                                                  predicate:(i_brand_id is not null and i_category_id is not null and i_class_id is not null and i_item_sk is not null)
+                                                                                   Please refer to the previous TableScan [TS_91]
+                                                                          <-Reducer 88 [SIMPLE_EDGE]
+                                                                            SHUFFLE [RS_336]
+                                                                              PartitionCols:_col1
+                                                                              Merge Join Operator [MERGEJOIN_860] (rows=158402938 width=135)
+                                                                                Conds:RS_1234._col0=RS_1071._col0(Inner),Output:["_col1"]
+                                                                              <-Map 86 [SIMPLE_EDGE] vectorized
+                                                                                SHUFFLE [RS_1071]
+                                                                                  PartitionCols:_col0
+                                                                                   Please refer to the previous Select Operator [SEL_1068]
+                                                                              <-Map 90 [SIMPLE_EDGE] vectorized
+                                                                                SHUFFLE [RS_1234]
+                                                                                  PartitionCols:_col0
+                                                                                  Select Operator [SEL_1233] (rows=144002668 width=135)
+                                                                                    Output:["_col0","_col1"]
+                                                                                    Filter Operator [FIL_1232] (rows=144002668 width=135)
+                                                                                      predicate:(ws_item_sk is not null and ws_sold_date_sk is not null)
+                                                                                      TableScan [TS_135] (rows=144002668 width=135)
+                                                                                        default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk"]
                   <-Reducer 16 [CONTAINS]
-                    Reduce Output Operator [RS_931]
+                    Reduce Output Operator [RS_935]
                       PartitionCols:_col0, _col1, _col2, _col3, _col4
-                      Group By Operator [GBY_930] (rows=2032776160 width=237)
+                      Group By Operator [GBY_934] (rows=2032776160 width=237)
                         Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(_col4)","sum(_col5)"],keys:_col0, _col1, _col2, _col3, 0L
-                        Select Operator [SEL_928] (rows=58081078 width=264)
-                          Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                          Filter Operator [FIL_927] (rows=58081078 width=264)
-                            predicate:(_col5 > _col1)
-                            Merge Join Operator [MERGEJOIN_926] (rows=174243235 width=264)
-                              Conds:(Inner),(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6"]
-                            <-Reducer 15 [CUSTOM_SIMPLE_EDGE] vectorized
-                              PARTITION_ONLY_SHUFFLE [RS_1160]
-                                Select Operator [SEL_1159] (rows=1 width=8)
-                                  Filter Operator [FIL_1158] (rows=1 width=8)
-                                    predicate:(sq_count_check(_col0) <= 1)
-                                    Group By Operator [GBY_1157] (rows=1 width=8)
-                                      Output:["_col0"],aggregations:["count()"]
-                                      Select Operator [SEL_1156] (rows=1 width=8)
-                                        Group By Operator [GBY_1155] (rows=1 width=8)
-                                          Output:["_col0"],aggregations:["count(VALUE._col0)"]
-                                        <-Union 14 [CUSTOM_SIMPLE_EDGE]
-                                          <-Reducer 13 [CONTAINS]
-                                            Reduce Output Operator [RS_925]
-                                              Group By Operator [GBY_924] (rows=1 width=8)
-                                                Output:["_col0"],aggregations:["count(_col0)"]
-                                                Select Operator [SEL_923] (rows=1108786976 width=108)
-                                                  Output:["_col0"]
-                                                  Select Operator [SEL_921] (rows=633595212 width=88)
+                        Top N Key Operator [TNK_933] (rows=406555232 width=237)
+                          keys:_col0, _col1, _col2, _col3, 0L,sort order:+++++,top n:100
+                          Select Operator [SEL_931] (rows=58081078 width=264)
+                            Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
+                            Filter Operator [FIL_930] (rows=58081078 width=264)
+                              predicate:(_col5 > _col1)
+                              Merge Join Operator [MERGEJOIN_929] (rows=174243235 width=264)
+                                Conds:(Inner),(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6"]
+                              <-Reducer 15 [CUSTOM_SIMPLE_EDGE] vectorized
+                                PARTITION_ONLY_SHUFFLE [RS_1164]
+                                  Select Operator [SEL_1163] (rows=1 width=8)
+                                    Filter Operator [FIL_1162] (rows=1 width=8)
+                                      predicate:(sq_count_check(_col0) <= 1)
+                                      Group By Operator [GBY_1161] (rows=1 width=8)
+                                        Output:["_col0"],aggregations:["count()"]
+                                        Select Operator [SEL_1160] (rows=1 width=8)
+                                          Group By Operator [GBY_1159] (rows=1 width=8)
+                                            Output:["_col0"],aggregations:["count(VALUE._col0)"]
+                                          <-Union 14 [CUSTOM_SIMPLE_EDGE]
+                                            <-Reducer 13 [CONTAINS]
+                                              Reduce Output Operator [RS_928]
+                                                Group By Operator [GBY_927] (rows=1 width=8)
+                                                  Output:["_col0"],aggregations:["count(_col0)"]
+                                                  Select Operator [SEL_926] (rows=1108786976 width=108)
                                                     Output:["_col0"]
-                                                    Merge Join Operator [MERGEJOIN_920] (rows=633595212 width=88)
-                                                      Conds:RS_1062._col0=RS_1072._col0(Inner),Output:["_col1"]
-                                                    <-Map 86 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1072]
-                                                        PartitionCols:_col0
-                                                         Please refer to the previous Select Operator [SEL_1064]
-                                                    <-Map 1 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1062]
-                                                        PartitionCols:_col0
-                                                         Please refer to the previous Select Operator [SEL_1059]
-                                          <-Reducer 20 [CONTAINS]
-                                            Reduce Output Operator [RS_949]
-                                              Group By Operator [GBY_948] (rows=1 width=8)
-                                                Output:["_col0"],aggregations:["count(_col0)"]
-                                                Select Operator [SEL_947] (rows=1108786976 width=108)
-                                                  Output:["_col0"]
-                                                  Select Operator [SEL_945] (rows=316788826 width=135)
+                                                    Select Operator [SEL_924] (rows=633595212 width=88)
+                                                      Output:["_col0"]
+                                                      Merge Join Operator [MERGEJOIN_923] (rows=633595212 width=88)
+                                                        Conds:RS_1066._col0=RS_1076._col0(Inner),Output:["_col1"]
+                                                      <-Map 86 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1076]
+                                                          PartitionCols:_col0
+                                                           Please refer to the previous Select Operator [SEL_1068]
+                                                      <-Map 1 [SIMPLE_EDGE] vectorized
+                                                        SHUFFLE [RS_1066]
+                                                          PartitionCols:_col0
+                                                           Please refer to the previous Select Operator [SEL_1063]
+                                            <-Reducer 20 [CONTAINS]
+                                              Reduce Output Operator [RS_953]
+                                                Group By Operator [GBY_952] (rows=1 width=8)
+                                                  Output:["_col0"],aggregations:["count(_col0)"]
+                                                  Select Operator [SEL_951] (rows=1108786976 width=108)
                                                     Output:["_col0"]
-                                                    Merge Join Operator [MERGEJOIN_944] (rows=316788826 width=135)
-                                                      Conds:RS_1179._col0=RS_1186._col0(Inner),Output:["_col1"]
-                                                    <-Map 21 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1186]
-                                                        PartitionCols:_col0
-                                                         Please refer to the previous Select Operator [SEL_1181]
-                                                    <-Map 17 [SIMPLE_EDGE] vectorized
-                                                      SHUFFLE [RS_1179]
-                                                        PartitionCols:_col0
-                                                         Please refer to the previous Select Operator [SEL_1176]
-                                          <-Reducer 34 [CONTAINS]
-                                            Reduce Output Operator [RS_985]
-                                              Group By Operator [GBY_984] (rows=1 width=8)
-                                                Output:["_col0"],aggregations:["count(_col0)"]
-                                                Select Operator [SEL_983] (rows=1108786976 width=108)
-                                                  Output:["_col0"]
-                                                  Select Operator [SEL_981] (rows=158402938 width=135)
+                                                    Select Operator [SEL_949] (rows=316788826 width=135)
+                                                      Output:["_col0"]
+                                                      Merge Join Operator [MERGEJOIN_948] (rows=316788826 width=135)
+                           

<TRUNCATED>