http://git-wip-us.apache.org/repos/asf/hive/blob/e8f283cf/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 6366d14..4d27064 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[893][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 5' is a cross product -Warning: Shuffle Join MERGEJOIN[894][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 12' is a cross product -Warning: Shuffle Join MERGEJOIN[895][tables = [$hdt$_2, $hdt$_3, $hdt$_1]] in Stage 'Reducer 16' is a cross product +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 PREHOOK: query: explain with cross_items as (select i_item_sk ss_item_sk @@ -281,203 +281,203 @@ Stage-0 limit:100 Stage-1 Reducer 8 vectorized - File Output Operator [FS_972] - Limit [LIM_971] (rows=100 width=237) + File Output Operator [FS_1134] + Limit [LIM_1133] (rows=100 width=237) Number of rows:100 - Select Operator [SEL_970] (rows=1016388080 width=237) + Select Operator [SEL_1132] (rows=1016388080 width=237) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 7 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_969] - Select Operator [SEL_968] (rows=1016388080 width=237) + SHUFFLE [RS_1131] + Select Operator [SEL_1130] (rows=1016388080 width=237) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Group By Operator [GBY_967] (rows=1016388080 width=237) + Group By Operator [GBY_1129] (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_571] + Reduce Output Operator [RS_919] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_570] (rows=2032776160 width=237) + Group By Operator [GBY_918] (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_377] (rows=116155905 width=264) + Select Operator [SEL_916] (rows=116155905 width=264) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_376] (rows=116155905 width=264) + Filter Operator [FIL_915] (rows=116155905 width=264) predicate:(_col5 > _col1) - Merge Join Operator [MERGEJOIN_894] (rows=348467716 width=264) + 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_978] - Select Operator [SEL_977] (rows=1 width=8) - Filter Operator [FIL_976] (rows=1 width=8) + 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_975] (rows=1 width=8) + Group By Operator [GBY_1137] (rows=1 width=8) Output:["_col0"],aggregations:["count()"] - Select Operator [SEL_974] (rows=1 width=8) - Group By Operator [GBY_973] (rows=1 width=8) + 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_223] - Group By Operator [GBY_222] (rows=1 width=8) + Reduce Output Operator [RS_943] + Group By Operator [GBY_942] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_220] (rows=1108786976 width=108) + Select Operator [SEL_941] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_208] (rows=316788826 width=135) + Select Operator [SEL_939] (rows=316788826 width=135) Output:["_col0"] - Merge Join Operator [MERGEJOIN_864] (rows=316788826 width=135) - Conds:RS_1016._col0=RS_1022._col0(Inner),Output:["_col1"] + 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_1022] + SHUFFLE [RS_1184] PartitionCols:_col0 - Select Operator [SEL_1019] (rows=8116 width=1119) + Select Operator [SEL_1181] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_1018] (rows=8116 width=1119) + 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_1016] + SHUFFLE [RS_1178] PartitionCols:_col0 - Select Operator [SEL_1014] (rows=287989836 width=135) + Select Operator [SEL_1176] (rows=287989836 width=135) Output:["_col0","_col1"] - Filter Operator [FIL_1013] (rows=287989836 width=135) + 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_223] - Group By Operator [GBY_222] (rows=1 width=8) + Reduce Output Operator [RS_979] + Group By Operator [GBY_978] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_220] (rows=1108786976 width=108) + Select Operator [SEL_977] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_219] (rows=158402938 width=135) + Select Operator [SEL_975] (rows=158402938 width=135) Output:["_col0"] - Merge Join Operator [MERGEJOIN_865] (rows=158402938 width=135) - Conds:RS_1034._col0=RS_1040._col0(Inner),Output:["_col1"] + 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_1040] + SHUFFLE [RS_1202] PartitionCols:_col0 - Select Operator [SEL_1037] (rows=8116 width=1119) + Select Operator [SEL_1199] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_1036] (rows=8116 width=1119) + 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_1034] + SHUFFLE [RS_1196] PartitionCols:_col0 - Select Operator [SEL_1032] (rows=144002668 width=135) + Select Operator [SEL_1194] (rows=144002668 width=135) Output:["_col0","_col1"] - Filter Operator [FIL_1031] (rows=144002668 width=135) + 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_223] - Group By Operator [GBY_222] (rows=1 width=8) + Reduce Output Operator [RS_913] + Group By Operator [GBY_912] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_220] (rows=1108786976 width=108) + Select Operator [SEL_911] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_198] (rows=633595212 width=88) + Select Operator [SEL_909] (rows=633595212 width=88) Output:["_col0"] - Merge Join Operator [MERGEJOIN_863] (rows=633595212 width=88) - Conds:RS_899._col0=RS_908._col0(Inner),Output:["_col1"] + 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_908] + SHUFFLE [RS_1070] PartitionCols:_col0 - Select Operator [SEL_902] (rows=8116 width=1119) + Select Operator [SEL_1064] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_901] (rows=8116 width=1119) + 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_899] + SHUFFLE [RS_1061] PartitionCols:_col0 - Select Operator [SEL_897] (rows=575995635 width=88) + Select Operator [SEL_1059] (rows=575995635 width=88) Output:["_col0","_col1"] - Filter Operator [FIL_896] (rows=575995635 width=88) + 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_981] - Select Operator [SEL_980] (rows=1 width=120) + PARTITION_ONLY_SHUFFLE [RS_1143] + Select Operator [SEL_1142] (rows=1 width=120) Output:["_col0"] - Group By Operator [GBY_979] (rows=1 width=120) + 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_268] - Group By Operator [GBY_267] (rows=1 width=120) + 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_265] (rows=1108786976 width=108) + Select Operator [SEL_959] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_253] (rows=316788826 width=135) + Select Operator [SEL_957] (rows=316788826 width=135) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_867] (rows=316788826 width=135) - Conds:RS_1029._col0=RS_1023._col0(Inner),Output:["_col1","_col2"] + 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_1023] + SHUFFLE [RS_1185] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1019] + Please refer to the previous Select Operator [SEL_1181] <-Map 43 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1029] + SHUFFLE [RS_1191] PartitionCols:_col0 - Select Operator [SEL_1027] (rows=287989836 width=135) + Select Operator [SEL_1189] (rows=287989836 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1026] (rows=287989836 width=135) + 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_268] - Group By Operator [GBY_267] (rows=1 width=120) + 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_265] (rows=1108786976 width=108) + Select Operator [SEL_995] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_264] (rows=158402938 width=135) + Select Operator [SEL_993] (rows=158402938 width=135) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_868] (rows=158402938 width=135) - Conds:RS_1047._col0=RS_1041._col0(Inner),Output:["_col1","_col2"] + 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_1041] + SHUFFLE [RS_1203] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1037] + Please refer to the previous Select Operator [SEL_1199] <-Map 44 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1047] + SHUFFLE [RS_1209] PartitionCols:_col0 - Select Operator [SEL_1045] (rows=144002668 width=135) + Select Operator [SEL_1207] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1044] (rows=144002668 width=135) + 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_268] - Group By Operator [GBY_267] (rows=1 width=120) + 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_265] (rows=1108786976 width=108) + Select Operator [SEL_1013] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_243] (rows=633595212 width=88) + Select Operator [SEL_1011] (rows=633595212 width=88) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_866] (rows=633595212 width=88) - Conds:RS_1052._col0=RS_909._col0(Inner),Output:["_col1","_col2"] + 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_909] + SHUFFLE [RS_1071] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_902] + Please refer to the previous Select Operator [SEL_1064] <-Map 39 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1052] + SHUFFLE [RS_1214] PartitionCols:_col0 - Select Operator [SEL_1050] (rows=575995635 width=88) + Select Operator [SEL_1212] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1049] (rows=575995635 width=88) + 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_992] - Group By Operator [GBY_991] (rows=348467716 width=135) + 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] @@ -487,13 +487,13 @@ Stage-0 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_956._col0(Inner),RS_362._col1=RS_990._col0(Inner),Output:["_col2","_col3","_col8","_col9","_col10"] + 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_956] + SHUFFLE [RS_1118] PartitionCols:_col0 - Select Operator [SEL_944] (rows=462000 width=1436) + Select Operator [SEL_1106] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_935] (rows=462000 width=1436) + 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"] @@ -501,29 +501,29 @@ Stage-0 SHUFFLE [RS_362] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_869] (rows=316788826 width=135) - Conds:RS_984._col0=RS_927._col0(Inner),Output:["_col1","_col2","_col3"] + Conds:RS_1146._col0=RS_1089._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 49 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_927] + SHUFFLE [RS_1089] PartitionCols:_col0 - Select Operator [SEL_925] (rows=18262 width=1119) + Select Operator [SEL_1087] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_924] (rows=18262 width=1119) + 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_984] + SHUFFLE [RS_1146] PartitionCols:_col0 - Select Operator [SEL_983] (rows=287989836 width=135) + Select Operator [SEL_1145] (rows=287989836 width=135) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_982] (rows=287989836 width=135) + 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_990] + FORWARD [RS_1152] PartitionCols:_col0 - Group By Operator [GBY_989] (rows=254100 width=1436) + Group By Operator [GBY_1151] (rows=254100 width=1436) Output:["_col0"],keys:KEY._col0 <-Reducer 67 [SIMPLE_EDGE] SHUFFLE [RS_356] @@ -531,31 +531,31 @@ Stage-0 Group By Operator [GBY_355] (rows=508200 width=1436) Output:["_col0"],keys:_col0 Merge Join Operator [MERGEJOIN_876] (rows=508200 width=1436) - Conds:RS_952._col1, _col2, _col3=RS_988._col0, _col1, _col2(Inner),Output:["_col0"] + Conds:RS_1114._col1, _col2, _col3=RS_1150._col0, _col1, _col2(Inner),Output:["_col0"] <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_952] + SHUFFLE [RS_1114] PartitionCols:_col1, _col2, _col3 - Select Operator [SEL_940] (rows=462000 width=1436) + Select Operator [SEL_1102] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_931] (rows=462000 width=1436) + 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_988] + FORWARD [RS_1150] PartitionCols:_col0, _col1, _col2 - Select Operator [SEL_987] (rows=1 width=108) + Select Operator [SEL_1149] (rows=1 width=108) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_986] (rows=1 width=108) + Filter Operator [FIL_1148] (rows=1 width=108) predicate:(_col3 = 3L) - Group By Operator [GBY_985] (rows=304916424 width=108) + 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_1074] + Reduce Output Operator [RS_1236] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1073] (rows=609832849 width=108) + 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_1072] (rows=348477374 width=88) + 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] @@ -563,39 +563,39 @@ Stage-0 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_953._col0(Inner),Output:["_col5","_col6","_col7"] + Conds:RS_295._col1=RS_1115._col0(Inner),Output:["_col5","_col6","_col7"] <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_953] + SHUFFLE [RS_1115] PartitionCols:_col0 - Select Operator [SEL_941] (rows=462000 width=1436) + Select Operator [SEL_1103] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_932] (rows=462000 width=1436) + 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_1056._col0=RS_903._col0(Inner),Output:["_col1"] + Conds:RS_1218._col0=RS_1065._col0(Inner),Output:["_col1"] <-Map 86 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_903] + SHUFFLE [RS_1065] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_902] + Please refer to the previous Select Operator [SEL_1064] <-Map 84 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1056] + SHUFFLE [RS_1218] PartitionCols:_col0 - Select Operator [SEL_1055] (rows=575995635 width=88) + Select Operator [SEL_1217] (rows=575995635 width=88) Output:["_col0","_col1"] - Filter Operator [FIL_1054] (rows=575995635 width=88) + 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_1080] + Reduce Output Operator [RS_1242] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1079] (rows=609832849 width=108) + 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_1078] (rows=174233858 width=135) + 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] @@ -603,39 +603,39 @@ Stage-0 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_954._col0(Inner),Output:["_col5","_col6","_col7"] + Conds:RS_315._col1=RS_1116._col0(Inner),Output:["_col5","_col6","_col7"] <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_954] + SHUFFLE [RS_1116] PartitionCols:_col0 - Select Operator [SEL_942] (rows=462000 width=1436) + Select Operator [SEL_1104] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_933] (rows=462000 width=1436) + 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_1062._col0=RS_904._col0(Inner),Output:["_col1"] + Conds:RS_1224._col0=RS_1066._col0(Inner),Output:["_col1"] <-Map 86 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_904] + SHUFFLE [RS_1066] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_902] + Please refer to the previous Select Operator [SEL_1064] <-Map 89 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1062] + SHUFFLE [RS_1224] PartitionCols:_col0 - Select Operator [SEL_1061] (rows=287989836 width=135) + Select Operator [SEL_1223] (rows=287989836 width=135) Output:["_col0","_col1"] - Filter Operator [FIL_1060] (rows=287989836 width=135) + 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_1086] + Reduce Output Operator [RS_1248] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1085] (rows=609832849 width=108) + 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_1084] (rows=87121617 width=135) + 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] @@ -643,173 +643,173 @@ Stage-0 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_955._col0(Inner),Output:["_col5","_col6","_col7"] + Conds:RS_336._col1=RS_1117._col0(Inner),Output:["_col5","_col6","_col7"] <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_955] + SHUFFLE [RS_1117] PartitionCols:_col0 - Select Operator [SEL_943] (rows=462000 width=1436) + Select Operator [SEL_1105] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_934] (rows=462000 width=1436) + 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_1068._col0=RS_905._col0(Inner),Output:["_col1"] + Conds:RS_1230._col0=RS_1067._col0(Inner),Output:["_col1"] <-Map 86 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_905] + SHUFFLE [RS_1067] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_902] + Please refer to the previous Select Operator [SEL_1064] <-Map 90 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1068] + SHUFFLE [RS_1230] PartitionCols:_col0 - Select Operator [SEL_1067] (rows=144002668 width=135) + Select Operator [SEL_1229] (rows=144002668 width=135) Output:["_col0","_col1"] - Filter Operator [FIL_1066] (rows=144002668 width=135) + 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"] <-Reducer 16 [CONTAINS] - Reduce Output Operator [RS_571] + Reduce Output Operator [RS_931] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_570] (rows=2032776160 width=237) + Group By Operator [GBY_930] (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_567] (rows=58081078 width=264) + Select Operator [SEL_928] (rows=58081078 width=264) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_566] (rows=58081078 width=264) + Filter Operator [FIL_927] (rows=58081078 width=264) predicate:(_col5 > _col1) - Merge Join Operator [MERGEJOIN_895] (rows=174243235 width=264) + 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_998] - Select Operator [SEL_997] (rows=1 width=8) - Filter Operator [FIL_996] (rows=1 width=8) + 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_995] (rows=1 width=8) + Group By Operator [GBY_1157] (rows=1 width=8) Output:["_col0"],aggregations:["count()"] - Select Operator [SEL_994] (rows=1 width=8) - Group By Operator [GBY_993] (rows=1 width=8) + 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_413] - Group By Operator [GBY_412] (rows=1 width=8) + Reduce Output Operator [RS_925] + Group By Operator [GBY_924] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_410] (rows=1108786976 width=108) + Select Operator [SEL_923] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_388] (rows=633595212 width=88) + Select Operator [SEL_921] (rows=633595212 width=88) Output:["_col0"] - Merge Join Operator [MERGEJOIN_878] (rows=633595212 width=88) - Conds:RS_900._col0=RS_910._col0(Inner),Output:["_col1"] + 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_910] + SHUFFLE [RS_1072] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_902] + Please refer to the previous Select Operator [SEL_1064] <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_900] + SHUFFLE [RS_1062] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_897] + Please refer to the previous Select Operator [SEL_1059] <-Reducer 20 [CONTAINS] - Reduce Output Operator [RS_413] - Group By Operator [GBY_412] (rows=1 width=8) + Reduce Output Operator [RS_949] + Group By Operator [GBY_948] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_410] (rows=1108786976 width=108) + Select Operator [SEL_947] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_398] (rows=316788826 width=135) + Select Operator [SEL_945] (rows=316788826 width=135) Output:["_col0"] - Merge Join Operator [MERGEJOIN_879] (rows=316788826 width=135) - Conds:RS_1017._col0=RS_1024._col0(Inner),Output:["_col1"] + 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_1024] + SHUFFLE [RS_1186] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1019] + Please refer to the previous Select Operator [SEL_1181] <-Map 17 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1017] + SHUFFLE [RS_1179] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1014] + Please refer to the previous Select Operator [SEL_1176] <-Reducer 34 [CONTAINS] - Reduce Output Operator [RS_413] - Group By Operator [GBY_412] (rows=1 width=8) + Reduce Output Operator [RS_985] + Group By Operator [GBY_984] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_410] (rows=1108786976 width=108) + Select Operator [SEL_983] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_409] (rows=158402938 width=135) + Select Operator [SEL_981] (rows=158402938 width=135) Output:["_col0"] - Merge Join Operator [MERGEJOIN_880] (rows=158402938 width=135) - Conds:RS_1035._col0=RS_1042._col0(Inner),Output:["_col1"] + Merge Join Operator [MERGEJOIN_980] (rows=158402938 width=135) + Conds:RS_1197._col0=RS_1204._col0(Inner),Output:["_col1"] <-Map 35 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1042] + SHUFFLE [RS_1204] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1037] + Please refer to the previous Select Operator [SEL_1199] <-Map 31 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1035] + SHUFFLE [RS_1197] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1032] + Please refer to the previous Select Operator [SEL_1194] <-Reducer 30 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1001] - Select Operator [SEL_1000] (rows=1 width=120) + PARTITION_ONLY_SHUFFLE [RS_1163] + Select Operator [SEL_1162] (rows=1 width=120) Output:["_col0"] - Group By Operator [GBY_999] (rows=1 width=120) + Group By Operator [GBY_1161] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"] <-Union 29 [CUSTOM_SIMPLE_EDGE] <-Reducer 28 [CONTAINS] - Reduce Output Operator [RS_458] - Group By Operator [GBY_457] (rows=1 width=120) + Reduce Output Operator [RS_967] + Group By Operator [GBY_966] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_455] (rows=1108786976 width=108) + Select Operator [SEL_965] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_443] (rows=316788826 width=135) + Select Operator [SEL_963] (rows=316788826 width=135) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_882] (rows=316788826 width=135) - Conds:RS_1030._col0=RS_1025._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_962] (rows=316788826 width=135) + Conds:RS_1192._col0=RS_1187._col0(Inner),Output:["_col1","_col2"] <-Map 21 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1025] + SHUFFLE [RS_1187] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1019] + Please refer to the previous Select Operator [SEL_1181] <-Map 43 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1030] + SHUFFLE [RS_1192] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1027] + Please refer to the previous Select Operator [SEL_1189] <-Reducer 38 [CONTAINS] - Reduce Output Operator [RS_458] - Group By Operator [GBY_457] (rows=1 width=120) + Reduce Output Operator [RS_1003] + Group By Operator [GBY_1002] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_455] (rows=1108786976 width=108) + Select Operator [SEL_1001] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_454] (rows=158402938 width=135) + Select Operator [SEL_999] (rows=158402938 width=135) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_883] (rows=158402938 width=135) - Conds:RS_1048._col0=RS_1043._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_998] (rows=158402938 width=135) + Conds:RS_1210._col0=RS_1205._col0(Inner),Output:["_col1","_col2"] <-Map 35 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1043] + SHUFFLE [RS_1205] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1037] + Please refer to the previous Select Operator [SEL_1199] <-Map 44 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1048] + SHUFFLE [RS_1210] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1045] + Please refer to the previous Select Operator [SEL_1207] <-Reducer 42 [CONTAINS] - Reduce Output Operator [RS_458] - Group By Operator [GBY_457] (rows=1 width=120) + Reduce Output Operator [RS_1021] + Group By Operator [GBY_1020] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_455] (rows=1108786976 width=108) + Select Operator [SEL_1019] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_433] (rows=633595212 width=88) + Select Operator [SEL_1017] (rows=633595212 width=88) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_881] (rows=633595212 width=88) - Conds:RS_1053._col0=RS_911._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_1016] (rows=633595212 width=88) + Conds:RS_1215._col0=RS_1073._col0(Inner),Output:["_col1","_col2"] <-Map 86 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_911] + SHUFFLE [RS_1073] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_902] + Please refer to the previous Select Operator [SEL_1064] <-Map 39 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1053] + SHUFFLE [RS_1215] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1050] + Please refer to the previous Select Operator [SEL_1212] <-Reducer 55 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1012] - Group By Operator [GBY_1011] (rows=174243235 width=135) + PARTITION_ONLY_SHUFFLE [RS_1174] + Group By Operator [GBY_1173] (rows=174243235 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"],keys:KEY._col0, KEY._col1, KEY._col2 <-Reducer 54 [SIMPLE_EDGE] SHUFFLE [RS_559] @@ -819,37 +819,37 @@ Stage-0 Select Operator [SEL_556] (rows=348486471 width=135) Output:["_col0","_col1","_col2","_col3"] Merge Join Operator [MERGEJOIN_892] (rows=348486471 width=135) - Conds:RS_552._col1=RS_958._col0(Inner),RS_552._col1=RS_1010._col0(Inner),Output:["_col2","_col3","_col8","_col9","_col10"] + Conds:RS_552._col1=RS_1120._col0(Inner),RS_552._col1=RS_1172._col0(Inner),Output:["_col2","_col3","_col8","_col9","_col10"] <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_958] + SHUFFLE [RS_1120] PartitionCols:_col0 - Select Operator [SEL_946] (rows=462000 width=1436) + Select Operator [SEL_1108] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_937] (rows=462000 width=1436) + Filter Operator [FIL_1099] (rows=462000 width=1436) predicate:i_item_sk is not null Please refer to the previous TableScan [TS_91] <-Reducer 53 [SIMPLE_EDGE] SHUFFLE [RS_552] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_884] (rows=158402938 width=135) - Conds:RS_1004._col0=RS_928._col0(Inner),Output:["_col1","_col2","_col3"] + Conds:RS_1166._col0=RS_1090._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 49 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_928] + SHUFFLE [RS_1090] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_925] + Please refer to the previous Select Operator [SEL_1087] <-Map 92 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1004] + SHUFFLE [RS_1166] PartitionCols:_col0 - Select Operator [SEL_1003] (rows=144002668 width=135) + Select Operator [SEL_1165] (rows=144002668 width=135) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_1002] (rows=144002668 width=135) + Filter Operator [FIL_1164] (rows=144002668 width=135) predicate:(ws_item_sk is not null and ws_sold_date_sk is not null) TableScan [TS_461] (rows=144002668 width=135) default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_quantity","ws_list_price"] <-Reducer 77 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_1010] + FORWARD [RS_1172] PartitionCols:_col0 - Group By Operator [GBY_1009] (rows=254100 width=1436) + Group By Operator [GBY_1171] (rows=254100 width=1436) Output:["_col0"],keys:KEY._col0 <-Reducer 76 [SIMPLE_EDGE] SHUFFLE [RS_546] @@ -857,198 +857,198 @@ Stage-0 Group By Operator [GBY_545] (rows=508200 width=1436) Output:["_col0"],keys:_col0 Merge Join Operator [MERGEJOIN_891] (rows=508200 width=1436) - Conds:RS_957._col1, _col2, _col3=RS_1008._col0, _col1, _col2(Inner),Output:["_col0"] + Conds:RS_1119._col1, _col2, _col3=RS_1170._col0, _col1, _col2(Inner),Output:["_col0"] <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_957] + SHUFFLE [RS_1119] PartitionCols:_col1, _col2, _col3 - Select Operator [SEL_945] (rows=462000 width=1436) + Select Operator [SEL_1107] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_936] (rows=462000 width=1436) + 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 75 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_1008] + FORWARD [RS_1170] PartitionCols:_col0, _col1, _col2 - Select Operator [SEL_1007] (rows=1 width=108) + Select Operator [SEL_1169] (rows=1 width=108) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1006] (rows=1 width=108) + Filter Operator [FIL_1168] (rows=1 width=108) predicate:(_col3 = 3L) - Group By Operator [GBY_1005] (rows=304916424 width=108) + Group By Operator [GBY_1167] (rows=304916424 width=108) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2 <-Union 74 [SIMPLE_EDGE] <-Reducer 73 [CONTAINS] vectorized - Reduce Output Operator [RS_1077] + Reduce Output Operator [RS_1239] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1076] (rows=609832849 width=108) + Group By Operator [GBY_1238] (rows=609832849 width=108) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2 - Group By Operator [GBY_1075] (rows=348477374 width=88) + Group By Operator [GBY_1237] (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_490] PartitionCols:_col0, _col1, _col2 Please refer to the previous Group By Operator [GBY_299] <-Reducer 80 [CONTAINS] vectorized - Reduce Output Operator [RS_1083] + Reduce Output Operator [RS_1245] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1082] (rows=609832849 width=108) + Group By Operator [GBY_1244] (rows=609832849 width=108) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2 - Group By Operator [GBY_1081] (rows=174233858 width=135) + Group By Operator [GBY_1243] (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_510] PartitionCols:_col0, _col1, _col2 Please refer to the previous Group By Operator [GBY_319] <-Reducer 83 [CONTAINS] vectorized - Reduce Output Operator [RS_1089] + Reduce Output Operator [RS_1251] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1088] (rows=609832849 width=108) + Group By Operator [GBY_1250] (rows=609832849 width=108) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(_col3)"],keys:_col0, _col1, _col2 - Group By Operator [GBY_1087] (rows=87121617 width=135) + Group By Operator [GBY_1249] (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_531] PartitionCols:_col0, _col1, _col2 Please refer to the previous Group By Operator [GBY_340] <-Reducer 5 [CONTAINS] - Reduce Output Operator [RS_571] + Reduce Output Operator [RS_907] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_570] (rows=2032776160 width=237) + Group By Operator [GBY_906] (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_188] (rows=232318249 width=217) + Select Operator [SEL_904] (rows=232318249 width=217) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_187] (rows=232318249 width=217) + Filter Operator [FIL_903] (rows=232318249 width=217) predicate:(_col5 > _col1) - Merge Join Operator [MERGEJOIN_893] (rows=696954748 width=217) + Merge Join Operator [MERGEJOIN_902] (rows=696954748 width=217) Conds:(Inner),(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6"] <-Reducer 24 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_920] - Select Operator [SEL_919] (rows=1 width=120) + PARTITION_ONLY_SHUFFLE [RS_1082] + Select Operator [SEL_1081] (rows=1 width=120) Output:["_col0"] - Group By Operator [GBY_918] (rows=1 width=120) + Group By Operator [GBY_1080] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"] <-Union 23 [CUSTOM_SIMPLE_EDGE] <-Reducer 22 [CONTAINS] - Reduce Output Operator [RS_79] - Group By Operator [GBY_78] (rows=1 width=120) + Reduce Output Operator [RS_955] + Group By Operator [GBY_954] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_76] (rows=1108786976 width=108) + Select Operator [SEL_953] (rows=11
<TRUNCATED>
