http://git-wip-us.apache.org/repos/asf/hive/blob/f2c4f319/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..6d996b5 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[1454][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 5' is a cross product +Warning: Shuffle Join MERGEJOIN[1466][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 12' is a cross product +Warning: Shuffle Join MERGEJOIN[1478][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 @@ -210,975 +210,1239 @@ POSTHOOK: type: QUERY Plan optimized by CBO. Vertex dependency in root stage +Map 1 <- Reducer 108 (BROADCAST_EDGE) +Map 100 <- Reducer 103 (BROADCAST_EDGE), Reducer 71 (BROADCAST_EDGE) +Map 110 <- Reducer 105 (BROADCAST_EDGE), Reducer 74 (BROADCAST_EDGE) +Map 111 <- Reducer 107 (BROADCAST_EDGE), Reducer 77 (BROADCAST_EDGE) +Map 112 <- Reducer 58 (BROADCAST_EDGE), Reducer 81 (BROADCAST_EDGE), Reducer 98 (BROADCAST_EDGE) +Map 113 <- Reducer 62 (BROADCAST_EDGE), Reducer 91 (BROADCAST_EDGE), Reducer 99 (BROADCAST_EDGE) +Map 17 <- Reducer 22 (BROADCAST_EDGE) +Map 33 <- Reducer 38 (BROADCAST_EDGE) +Map 43 <- Reducer 109 (BROADCAST_EDGE) +Map 47 <- Reducer 26 (BROADCAST_EDGE) +Map 48 <- Reducer 40 (BROADCAST_EDGE) +Map 49 <- Reducer 54 (BROADCAST_EDGE), Reducer 66 (BROADCAST_EDGE), Reducer 78 (BROADCAST_EDGE) +Reducer 101 <- Map 100 (SIMPLE_EDGE), Map 102 (SIMPLE_EDGE) +Reducer 103 <- Map 102 (CUSTOM_SIMPLE_EDGE) +Reducer 104 <- Map 102 (SIMPLE_EDGE), Map 110 (SIMPLE_EDGE) +Reducer 105 <- Map 102 (CUSTOM_SIMPLE_EDGE) +Reducer 106 <- Map 102 (SIMPLE_EDGE), Map 111 (SIMPLE_EDGE) +Reducer 107 <- Map 102 (CUSTOM_SIMPLE_EDGE) +Reducer 108 <- Map 102 (CUSTOM_SIMPLE_EDGE) +Reducer 109 <- Map 102 (CUSTOM_SIMPLE_EDGE) Reducer 11 <- Union 10 (CUSTOM_SIMPLE_EDGE) -Reducer 12 <- Reducer 11 (CUSTOM_SIMPLE_EDGE), Reducer 27 (CUSTOM_SIMPLE_EDGE), Reducer 52 (CUSTOM_SIMPLE_EDGE), Union 6 (CONTAINS) -Reducer 13 <- Map 1 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE), Union 14 (CONTAINS) +Reducer 12 <- Reducer 11 (CUSTOM_SIMPLE_EDGE), Reducer 29 (CUSTOM_SIMPLE_EDGE), Reducer 57 (CUSTOM_SIMPLE_EDGE), Union 6 (CONTAINS) +Reducer 13 <- Map 1 (SIMPLE_EDGE), Map 102 (SIMPLE_EDGE), Union 14 (CONTAINS) Reducer 15 <- Union 14 (CUSTOM_SIMPLE_EDGE) -Reducer 16 <- Reducer 15 (CUSTOM_SIMPLE_EDGE), Reducer 30 (CUSTOM_SIMPLE_EDGE), Reducer 55 (CUSTOM_SIMPLE_EDGE), Union 6 (CONTAINS) +Reducer 16 <- Reducer 15 (CUSTOM_SIMPLE_EDGE), Reducer 32 (CUSTOM_SIMPLE_EDGE), Reducer 61 (CUSTOM_SIMPLE_EDGE), Union 6 (CONTAINS) Reducer 18 <- Map 17 (SIMPLE_EDGE), Map 21 (SIMPLE_EDGE), Union 3 (CONTAINS) Reducer 19 <- Map 17 (SIMPLE_EDGE), Map 21 (SIMPLE_EDGE), Union 10 (CONTAINS) -Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE), Union 3 (CONTAINS) +Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 102 (SIMPLE_EDGE), Union 3 (CONTAINS) Reducer 20 <- Map 17 (SIMPLE_EDGE), Map 21 (SIMPLE_EDGE), Union 14 (CONTAINS) -Reducer 22 <- Map 21 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE), Union 23 (CONTAINS) -Reducer 24 <- Union 23 (CUSTOM_SIMPLE_EDGE) -Reducer 25 <- Map 21 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE), Union 26 (CONTAINS) -Reducer 27 <- Union 26 (CUSTOM_SIMPLE_EDGE) -Reducer 28 <- Map 21 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE), Union 29 (CONTAINS) -Reducer 30 <- Union 29 (CUSTOM_SIMPLE_EDGE) -Reducer 32 <- Map 31 (SIMPLE_EDGE), Map 35 (SIMPLE_EDGE), Union 3 (CONTAINS) -Reducer 33 <- Map 31 (SIMPLE_EDGE), Map 35 (SIMPLE_EDGE), Union 10 (CONTAINS) -Reducer 34 <- Map 31 (SIMPLE_EDGE), Map 35 (SIMPLE_EDGE), Union 14 (CONTAINS) -Reducer 36 <- Map 35 (SIMPLE_EDGE), Map 44 (SIMPLE_EDGE), Union 23 (CONTAINS) -Reducer 37 <- Map 35 (SIMPLE_EDGE), Map 44 (SIMPLE_EDGE), Union 26 (CONTAINS) -Reducer 38 <- Map 35 (SIMPLE_EDGE), Map 44 (SIMPLE_EDGE), Union 29 (CONTAINS) +Reducer 22 <- Map 21 (CUSTOM_SIMPLE_EDGE) +Reducer 23 <- Map 21 (SIMPLE_EDGE), Map 47 (SIMPLE_EDGE), Union 24 (CONTAINS) +Reducer 25 <- Union 24 (CUSTOM_SIMPLE_EDGE) +Reducer 26 <- Map 21 (CUSTOM_SIMPLE_EDGE) +Reducer 27 <- Map 21 (SIMPLE_EDGE), Map 47 (SIMPLE_EDGE), Union 28 (CONTAINS) +Reducer 29 <- Union 28 (CUSTOM_SIMPLE_EDGE) +Reducer 30 <- Map 21 (SIMPLE_EDGE), Map 47 (SIMPLE_EDGE), Union 31 (CONTAINS) +Reducer 32 <- Union 31 (CUSTOM_SIMPLE_EDGE) +Reducer 34 <- Map 33 (SIMPLE_EDGE), Map 37 (SIMPLE_EDGE), Union 3 (CONTAINS) +Reducer 35 <- Map 33 (SIMPLE_EDGE), Map 37 (SIMPLE_EDGE), Union 10 (CONTAINS) +Reducer 36 <- Map 33 (SIMPLE_EDGE), Map 37 (SIMPLE_EDGE), Union 14 (CONTAINS) +Reducer 38 <- Map 37 (CUSTOM_SIMPLE_EDGE) +Reducer 39 <- Map 37 (SIMPLE_EDGE), Map 48 (SIMPLE_EDGE), Union 24 (CONTAINS) Reducer 4 <- Union 3 (CUSTOM_SIMPLE_EDGE) -Reducer 40 <- Map 39 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE), Union 23 (CONTAINS) -Reducer 41 <- Map 39 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE), Union 26 (CONTAINS) -Reducer 42 <- Map 39 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE), Union 29 (CONTAINS) -Reducer 46 <- Map 45 (SIMPLE_EDGE), Map 49 (SIMPLE_EDGE) -Reducer 47 <- Map 56 (SIMPLE_EDGE), Reducer 46 (SIMPLE_EDGE), Reducer 58 (ONE_TO_ONE_EDGE) -Reducer 48 <- Reducer 47 (SIMPLE_EDGE) -Reducer 5 <- Reducer 24 (CUSTOM_SIMPLE_EDGE), Reducer 4 (CUSTOM_SIMPLE_EDGE), Reducer 48 (CUSTOM_SIMPLE_EDGE), Union 6 (CONTAINS) -Reducer 50 <- Map 49 (SIMPLE_EDGE), Map 91 (SIMPLE_EDGE) -Reducer 51 <- Map 56 (SIMPLE_EDGE), Reducer 50 (SIMPLE_EDGE), Reducer 68 (ONE_TO_ONE_EDGE) +Reducer 40 <- Map 37 (CUSTOM_SIMPLE_EDGE) +Reducer 41 <- Map 37 (SIMPLE_EDGE), Map 48 (SIMPLE_EDGE), Union 28 (CONTAINS) +Reducer 42 <- Map 37 (SIMPLE_EDGE), Map 48 (SIMPLE_EDGE), Union 31 (CONTAINS) +Reducer 44 <- Map 102 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE), Union 24 (CONTAINS) +Reducer 45 <- Map 102 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE), Union 28 (CONTAINS) +Reducer 46 <- Map 102 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE), Union 31 (CONTAINS) +Reducer 5 <- Reducer 25 (CUSTOM_SIMPLE_EDGE), Reducer 4 (CUSTOM_SIMPLE_EDGE), Reducer 52 (CUSTOM_SIMPLE_EDGE), Union 6 (CONTAINS) +Reducer 50 <- Map 49 (SIMPLE_EDGE), Map 53 (SIMPLE_EDGE) +Reducer 51 <- Map 63 (SIMPLE_EDGE), Reducer 50 (SIMPLE_EDGE), Reducer 65 (ONE_TO_ONE_EDGE) Reducer 52 <- Reducer 51 (SIMPLE_EDGE) -Reducer 53 <- Map 49 (SIMPLE_EDGE), Map 92 (SIMPLE_EDGE) -Reducer 54 <- Map 56 (SIMPLE_EDGE), Reducer 53 (SIMPLE_EDGE), Reducer 77 (ONE_TO_ONE_EDGE) -Reducer 55 <- Reducer 54 (SIMPLE_EDGE) -Reducer 57 <- Map 56 (SIMPLE_EDGE), Reducer 62 (ONE_TO_ONE_EDGE) -Reducer 58 <- Reducer 57 (SIMPLE_EDGE) -Reducer 59 <- Map 56 (SIMPLE_EDGE), Reducer 85 (SIMPLE_EDGE) -Reducer 60 <- Reducer 59 (SIMPLE_EDGE), Union 61 (CONTAINS) -Reducer 62 <- Union 61 (SIMPLE_EDGE) -Reducer 63 <- Map 56 (SIMPLE_EDGE), Reducer 87 (SIMPLE_EDGE) -Reducer 64 <- Reducer 63 (SIMPLE_EDGE), Union 61 (CONTAINS) -Reducer 65 <- Map 56 (SIMPLE_EDGE), Reducer 88 (SIMPLE_EDGE) -Reducer 66 <- Reducer 65 (SIMPLE_EDGE), Union 61 (CONTAINS) -Reducer 67 <- Map 56 (SIMPLE_EDGE), Reducer 72 (ONE_TO_ONE_EDGE) -Reducer 68 <- Reducer 67 (SIMPLE_EDGE) -Reducer 69 <- Map 56 (SIMPLE_EDGE), Reducer 85 (SIMPLE_EDGE) +Reducer 54 <- Map 53 (CUSTOM_SIMPLE_EDGE) +Reducer 55 <- Map 112 (SIMPLE_EDGE), Map 53 (SIMPLE_EDGE) +Reducer 56 <- Map 63 (SIMPLE_EDGE), Reducer 55 (SIMPLE_EDGE), Reducer 80 (ONE_TO_ONE_EDGE) +Reducer 57 <- Reducer 56 (SIMPLE_EDGE) +Reducer 58 <- Map 53 (CUSTOM_SIMPLE_EDGE) +Reducer 59 <- Map 113 (SIMPLE_EDGE), Map 53 (SIMPLE_EDGE) +Reducer 60 <- Map 63 (SIMPLE_EDGE), Reducer 59 (SIMPLE_EDGE), Reducer 90 (ONE_TO_ONE_EDGE) +Reducer 61 <- Reducer 60 (SIMPLE_EDGE) +Reducer 62 <- Map 53 (CUSTOM_SIMPLE_EDGE) +Reducer 64 <- Map 63 (SIMPLE_EDGE), Reducer 70 (ONE_TO_ONE_EDGE) +Reducer 65 <- Reducer 64 (SIMPLE_EDGE) +Reducer 66 <- Reducer 65 (CUSTOM_SIMPLE_EDGE) +Reducer 67 <- Map 63 (SIMPLE_EDGE), Reducer 101 (SIMPLE_EDGE) +Reducer 68 <- Reducer 67 (SIMPLE_EDGE), Union 69 (CONTAINS) Reducer 7 <- Union 6 (SIMPLE_EDGE) -Reducer 70 <- Reducer 69 (SIMPLE_EDGE), Union 71 (CONTAINS) -Reducer 72 <- Union 71 (SIMPLE_EDGE) -Reducer 73 <- Reducer 69 (SIMPLE_EDGE), Union 74 (CONTAINS) -Reducer 75 <- Union 74 (SIMPLE_EDGE) -Reducer 76 <- Map 56 (SIMPLE_EDGE), Reducer 75 (ONE_TO_ONE_EDGE) -Reducer 77 <- Reducer 76 (SIMPLE_EDGE) -Reducer 78 <- Map 56 (SIMPLE_EDGE), Reducer 87 (SIMPLE_EDGE) -Reducer 79 <- Reducer 78 (SIMPLE_EDGE), Union 71 (CONTAINS) +Reducer 70 <- Union 69 (SIMPLE_EDGE) +Reducer 71 <- Map 63 (CUSTOM_SIMPLE_EDGE) +Reducer 72 <- Map 63 (SIMPLE_EDGE), Reducer 104 (SIMPLE_EDGE) +Reducer 73 <- Reducer 72 (SIMPLE_EDGE), Union 69 (CONTAINS) +Reducer 74 <- Map 63 (CUSTOM_SIMPLE_EDGE) +Reducer 75 <- Map 63 (SIMPLE_EDGE), Reducer 106 (SIMPLE_EDGE) +Reducer 76 <- Reducer 75 (SIMPLE_EDGE), Union 69 (CONTAINS) +Reducer 77 <- Map 63 (CUSTOM_SIMPLE_EDGE) +Reducer 78 <- Map 63 (CUSTOM_SIMPLE_EDGE) +Reducer 79 <- Map 63 (SIMPLE_EDGE), Reducer 85 (ONE_TO_ONE_EDGE) Reducer 8 <- Reducer 7 (SIMPLE_EDGE) -Reducer 80 <- Reducer 78 (SIMPLE_EDGE), Union 74 (CONTAINS) -Reducer 81 <- Map 56 (SIMPLE_EDGE), Reducer 88 (SIMPLE_EDGE) -Reducer 82 <- Reducer 81 (SIMPLE_EDGE), Union 71 (CONTAINS) -Reducer 83 <- Reducer 81 (SIMPLE_EDGE), Union 74 (CONTAINS) -Reducer 85 <- Map 84 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE) -Reducer 87 <- Map 86 (SIMPLE_EDGE), Map 89 (SIMPLE_EDGE) -Reducer 88 <- Map 86 (SIMPLE_EDGE), Map 90 (SIMPLE_EDGE) -Reducer 9 <- Map 1 (SIMPLE_EDGE), Map 86 (SIMPLE_EDGE), Union 10 (CONTAINS) +Reducer 80 <- Reducer 79 (SIMPLE_EDGE) +Reducer 81 <- Reducer 80 (CUSTOM_SIMPLE_EDGE) +Reducer 82 <- Map 63 (SIMPLE_EDGE), Reducer 101 (SIMPLE_EDGE) +Reducer 83 <- Reducer 82 (SIMPLE_EDGE), Union 84 (CONTAINS) +Reducer 85 <- Union 84 (SIMPLE_EDGE) +Reducer 86 <- Reducer 82 (SIMPLE_EDGE), Union 87 (CONTAINS) +Reducer 88 <- Union 87 (SIMPLE_EDGE) +Reducer 89 <- Map 63 (SIMPLE_EDGE), Reducer 88 (ONE_TO_ONE_EDGE) +Reducer 9 <- Map 1 (SIMPLE_EDGE), Map 102 (SIMPLE_EDGE), Union 10 (CONTAINS) +Reducer 90 <- Reducer 89 (SIMPLE_EDGE) +Reducer 91 <- Reducer 90 (CUSTOM_SIMPLE_EDGE) +Reducer 92 <- Map 63 (SIMPLE_EDGE), Reducer 104 (SIMPLE_EDGE) +Reducer 93 <- Reducer 92 (SIMPLE_EDGE), Union 84 (CONTAINS) +Reducer 94 <- Reducer 92 (SIMPLE_EDGE), Union 87 (CONTAINS) +Reducer 95 <- Map 63 (SIMPLE_EDGE), Reducer 106 (SIMPLE_EDGE) +Reducer 96 <- Reducer 95 (SIMPLE_EDGE), Union 84 (CONTAINS) +Reducer 97 <- Reducer 95 (SIMPLE_EDGE), Union 87 (CONTAINS) +Reducer 98 <- Map 63 (CUSTOM_SIMPLE_EDGE) +Reducer 99 <- Map 63 (CUSTOM_SIMPLE_EDGE) Stage-0 Fetch Operator limit:100 Stage-1 Reducer 8 vectorized - File Output Operator [FS_1134] - Limit [LIM_1133] (rows=100 width=237) + File Output Operator [FS_1739] + Limit [LIM_1738] (rows=100 width=237) Number of rows:100 - Select Operator [SEL_1132] (rows=1016388080 width=237) + Select Operator [SEL_1737] (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_1736] + Select Operator [SEL_1735] (rows=1016388080 width=237) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Group By Operator [GBY_1129] (rows=1016388080 width=237) + Group By Operator [GBY_1734] (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_1471] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_918] (rows=2032776160 width=237) + Group By Operator [GBY_1470] (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) + Select Operator [SEL_1468] (rows=116155905 width=264) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_915] (rows=116155905 width=264) + Filter Operator [FIL_1467] (rows=116155905 width=264) predicate:(_col5 > _col1) - Merge Join Operator [MERGEJOIN_914] (rows=348467716 width=264) + Merge Join Operator [MERGEJOIN_1466] (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) + PARTITION_ONLY_SHUFFLE [RS_1745] + Select Operator [SEL_1744] (rows=1 width=8) + Filter Operator [FIL_1743] (rows=1 width=8) predicate:(sq_count_check(_col0) <= 1) - Group By Operator [GBY_1137] (rows=1 width=8) + Group By Operator [GBY_1742] (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) + Select Operator [SEL_1741] (rows=1 width=8) + Group By Operator [GBY_1740] (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) + Reduce Output Operator [RS_1495] + Group By Operator [GBY_1494] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_941] (rows=1108786976 width=108) + Select Operator [SEL_1493] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_939] (rows=316788826 width=135) + Select Operator [SEL_1491] (rows=316788826 width=135) Output:["_col0"] - Merge Join Operator [MERGEJOIN_938] (rows=316788826 width=135) - Conds:RS_1178._col0=RS_1184._col0(Inner),Output:["_col1"] + Merge Join Operator [MERGEJOIN_1490] (rows=316788826 width=135) + Conds:RS_1817._col0=RS_1804._col0(Inner),Output:["_col1"] <-Map 21 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1184] + SHUFFLE [RS_1804] PartitionCols:_col0 - Select Operator [SEL_1181] (rows=8116 width=1119) + Select Operator [SEL_1799] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_1180] (rows=8116 width=1119) + Filter Operator [FIL_1798] (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] + SHUFFLE [RS_1817] PartitionCols:_col0 - Select Operator [SEL_1176] (rows=287989836 width=135) + Select Operator [SEL_1815] (rows=287989836 width=135) Output:["_col0","_col1"] - Filter Operator [FIL_1175] (rows=287989836 width=135) - predicate:cs_sold_date_sk is not null + Filter Operator [FIL_1814] (rows=287989836 width=135) + predicate:((cs_sold_date_sk BETWEEN DynamicValue(RS_17_date_dim_d_date_sk_min) AND DynamicValue(RS_17_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_17_date_dim_d_date_sk_bloom_filter))) and 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) + <-Reducer 22 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1813] + Group By Operator [GBY_1812] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 21 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1810] + Group By Operator [GBY_1808] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1801] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1799] + <-Reducer 35 [CONTAINS] + Reduce Output Operator [RS_1531] + Group By Operator [GBY_1530] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_977] (rows=1108786976 width=108) + Select Operator [SEL_1529] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_975] (rows=158402938 width=135) + Select Operator [SEL_1527] (rows=158402938 width=135) 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] + Merge Join Operator [MERGEJOIN_1526] (rows=158402938 width=135) + Conds:RS_1845._col0=RS_1832._col0(Inner),Output:["_col1"] + <-Map 37 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1832] PartitionCols:_col0 - Select Operator [SEL_1199] (rows=8116 width=1119) + Select Operator [SEL_1827] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_1198] (rows=8116 width=1119) + Filter Operator [FIL_1826] (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] + <-Map 33 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1845] PartitionCols:_col0 - Select Operator [SEL_1194] (rows=144002668 width=135) + Select Operator [SEL_1843] (rows=144002668 width=135) Output:["_col0","_col1"] - Filter Operator [FIL_1193] (rows=144002668 width=135) - predicate:ws_sold_date_sk is not null + Filter Operator [FIL_1842] (rows=144002668 width=135) + predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_28_date_dim_d_date_sk_min) AND DynamicValue(RS_28_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_28_date_dim_d_date_sk_bloom_filter))) and 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 38 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1841] + Group By Operator [GBY_1840] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 37 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1838] + Group By Operator [GBY_1836] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1829] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1827] <-Reducer 9 [CONTAINS] - Reduce Output Operator [RS_913] - Group By Operator [GBY_912] (rows=1 width=8) + Reduce Output Operator [RS_1465] + Group By Operator [GBY_1464] (rows=1 width=8) Output:["_col0"],aggregations:["count(_col0)"] - Select Operator [SEL_911] (rows=1108786976 width=108) + Select Operator [SEL_1463] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_909] (rows=633595212 width=88) + Select Operator [SEL_1461] (rows=633595212 width=88) 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] + Merge Join Operator [MERGEJOIN_1460] (rows=633595212 width=88) + Conds:RS_1641._col0=RS_1622._col0(Inner),Output:["_col1"] + <-Map 102 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1622] PartitionCols:_col0 - Select Operator [SEL_1064] (rows=8116 width=1119) + Select Operator [SEL_1611] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_1063] (rows=8116 width=1119) + Filter Operator [FIL_1610] (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] + SHUFFLE [RS_1641] PartitionCols:_col0 - Select Operator [SEL_1059] (rows=575995635 width=88) + Select Operator [SEL_1639] (rows=575995635 width=88) Output:["_col0","_col1"] - Filter Operator [FIL_1058] (rows=575995635 width=88) - predicate:ss_sold_date_sk is not null + Filter Operator [FIL_1638] (rows=575995635 width=88) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_7_date_dim_d_date_sk_min) AND DynamicValue(RS_7_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_7_date_dim_d_date_sk_bloom_filter))) and 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) + <-Reducer 108 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1637] + Group By Operator [GBY_1636] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 102 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1634] + Group By Operator [GBY_1629] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1619] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1611] + <-Reducer 29 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1748] + Select Operator [SEL_1747] (rows=1 width=120) Output:["_col0"] - Group By Operator [GBY_1141] (rows=1 width=120) + Group By Operator [GBY_1746] (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) + <-Union 28 [CUSTOM_SIMPLE_EDGE] + <-Reducer 27 [CONTAINS] + Reduce Output Operator [RS_1513] + Group By Operator [GBY_1512] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_959] (rows=1108786976 width=108) + Select Operator [SEL_1511] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_957] (rows=316788826 width=135) + Select Operator [SEL_1509] (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"] + Merge Join Operator [MERGEJOIN_1508] (rows=316788826 width=135) + Conds:RS_1824._col0=RS_1805._col0(Inner),Output:["_col1","_col2"] <-Map 21 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1185] + SHUFFLE [RS_1805] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1181] - <-Map 43 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1191] + Please refer to the previous Select Operator [SEL_1799] + <-Map 47 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1824] PartitionCols:_col0 - Select Operator [SEL_1189] (rows=287989836 width=135) + Select Operator [SEL_1822] (rows=287989836 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1188] (rows=287989836 width=135) - predicate:cs_sold_date_sk is not null + Filter Operator [FIL_1821] (rows=287989836 width=135) + predicate:((cs_sold_date_sk BETWEEN DynamicValue(RS_62_date_dim_d_date_sk_min) AND DynamicValue(RS_62_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_62_date_dim_d_date_sk_bloom_filter))) and 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) + <-Reducer 26 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1820] + Group By Operator [GBY_1819] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 21 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1811] + Group By Operator [GBY_1809] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1803] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1799] + <-Reducer 41 [CONTAINS] + Reduce Output Operator [RS_1549] + Group By Operator [GBY_1548] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_995] (rows=1108786976 width=108) + Select Operator [SEL_1547] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_993] (rows=158402938 width=135) + Select Operator [SEL_1545] (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] + Merge Join Operator [MERGEJOIN_1544] (rows=158402938 width=135) + Conds:RS_1852._col0=RS_1833._col0(Inner),Output:["_col1","_col2"] + <-Map 37 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1833] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1199] - <-Map 44 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1209] + Please refer to the previous Select Operator [SEL_1827] + <-Map 48 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1852] PartitionCols:_col0 - Select Operator [SEL_1207] (rows=144002668 width=135) + Select Operator [SEL_1850] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1206] (rows=144002668 width=135) - predicate:ws_sold_date_sk is not null + Filter Operator [FIL_1849] (rows=144002668 width=135) + predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_73_date_dim_d_date_sk_min) AND DynamicValue(RS_73_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_73_date_dim_d_date_sk_bloom_filter))) and 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) + <-Reducer 40 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1848] + Group By Operator [GBY_1847] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 37 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1839] + Group By Operator [GBY_1837] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1831] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1827] + <-Reducer 45 [CONTAINS] + Reduce Output Operator [RS_1567] + Group By Operator [GBY_1566] (rows=1 width=120) Output:["_col0","_col1"],aggregations:["sum(_col0)","count(_col0)"] - Select Operator [SEL_1013] (rows=1108786976 width=108) + Select Operator [SEL_1565] (rows=1108786976 width=108) Output:["_col0"] - Select Operator [SEL_1011] (rows=633595212 width=88) + Select Operator [SEL_1563] (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] + Merge Join Operator [MERGEJOIN_1562] (rows=633595212 width=88) + Conds:RS_1859._col0=RS_1623._col0(Inner),Output:["_col1","_col2"] + <-Map 102 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1623] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1064] - <-Map 39 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1214] + Please refer to the previous Select Operator [SEL_1611] + <-Map 43 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1859] PartitionCols:_col0 - Select Operator [SEL_1212] (rows=575995635 width=88) + Select Operator [SEL_1857] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1211] (rows=575995635 width=88) - predicate:ss_sold_date_sk is not null + Filter Operator [FIL_1856] (rows=575995635 width=88) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_52_date_dim_d_date_sk_min) AND DynamicValue(RS_52_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_52_date_dim_d_date_sk_bloom_filter))) and 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) + <-Reducer 109 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1855] + Group By Operator [GBY_1854] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 102 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1635] + Group By Operator [GBY_1630] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1621] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1611] + <-Reducer 57 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1768] + Group By Operator [GBY_1767] (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] + <-Reducer 56 [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] + Merge Join Operator [MERGEJOIN_1429] (rows=696935432 width=135) + Conds:RS_362._col1=RS_1699._col0(Inner),RS_362._col1=RS_1758._col0(Inner),Output:["_col2","_col3","_col8","_col9","_col10"] + <-Map 63 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1699] PartitionCols:_col0 - Select Operator [SEL_1106] (rows=462000 width=1436) + Select Operator [SEL_1683] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_1097] (rows=462000 width=1436) + Filter Operator [FIL_1674] (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] + <-Reducer 80 [ONE_TO_ONE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1758] PartitionCols:_col0 - Group By Operator [GBY_1151] (rows=254100 width=1436) + Group By Operator [GBY_1757] (rows=254100 width=1436) Output:["_col0"],keys:KEY._col0 - <-Reducer 67 [SIMPLE_EDGE] + <-Reducer 79 [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] + Merge Join Operator [MERGEJOIN_1428] (rows=508200 width=1436) + Conds:RS_1695._col1, _col2, _col3=RS_1756._col0, _col1, _col2(Inner),Output:["_col0"] + <-Map 63 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1695] PartitionCols:_col1, _col2, _col3 - Select Operator [SEL_1102] (rows=462000 width=1436) + Select Operator [SEL_1679] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_1093] (rows=462000 width=1436) + Filter Operator [FIL_1670] (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] + <-Reducer 85 [ONE_TO_ONE_EDGE] vectorized + FORWARD [RS_1756] PartitionCols:_col0, _col1, _col2 - Select Operator [SEL_1149] (rows=1 width=108) + Select Operator [SEL_1755] (rows=1 width=108) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1148] (rows=1 width=108) + Filter Operator [FIL_1754] (rows=1 width=108) predicate:(_col3 = 3L) - Group By Operator [GBY_1147] (rows=304916424 width=108) + Group By Operator [GBY_1753] (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] + <-Union 84 [SIMPLE_EDGE] + <-Reducer 83 [CONTAINS] vectorized + Reduce Output Operator [RS_1893] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1235] (rows=609832849 width=108) + Group By Operator [GBY_1892] (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) + Group By Operator [GBY_1891] (rows=348477374 width=88) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2 - <-Reducer 69 [SIMPLE_EDGE] + <-Reducer 82 [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] + Merge Join Operator [MERGEJOIN_1423] (rows=696954748 width=88) + Conds:RS_295._col1=RS_1696._col0(Inner),Output:["_col5","_col6","_col7"] + <-Map 63 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1696] PartitionCols:_col0 - Select Operator [SEL_1103] (rows=462000 width=1436) + Select Operator [SEL_1680] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_1094] (rows=462000 width=1436) + Filter Operator [FIL_1671] (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] + <-Reducer 101 [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] + Merge Join Operator [MERGEJOIN_1407] (rows=633595212 width=88) + Conds:RS_1867._col0=RS_1612._col0(Inner),Output:["_col1"] + <-Map 102 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1612] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1064] - <-Map 84 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1218] + Please refer to the previous Select Operator [SEL_1611] + <-Map 100 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1867] PartitionCols:_col0 - Select Operator [SEL_1217] (rows=575995635 width=88) + Select Operator [SEL_1866] (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) + Filter Operator [FIL_1865] (rows=575995635 width=88) + predicate:((ss_item_sk BETWEEN DynamicValue(RS_107_iss_i_item_sk_min) AND DynamicValue(RS_107_iss_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_107_iss_i_item_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_104_d1_d_date_sk_min) AND DynamicValue(RS_104_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_104_d1_d_date_sk_bloom_filter))) and 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] + <-Reducer 103 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1862] + Group By Operator [GBY_1861] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 102 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1631] + Group By Operator [GBY_1626] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1613] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1611] + <-Reducer 71 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1864] + Group By Operator [GBY_1863] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 63 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1710] + Group By Operator [GBY_1704] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1688] (rows=462000 width=1436) + Output:["_col0"] + Select Operator [SEL_1677] (rows=462000 width=1436) + Output:["_col0","_col1","_col2","_col3"] + Filter Operator [FIL_1668] (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 93 [CONTAINS] vectorized + Reduce Output Operator [RS_1899] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1241] (rows=609832849 width=108) + Group By Operator [GBY_1898] (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) + Group By Operator [GBY_1897] (rows=174233858 width=135) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2 - <-Reducer 78 [SIMPLE_EDGE] + <-Reducer 92 [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] + Merge Join Operator [MERGEJOIN_1425] (rows=348467716 width=135) + Conds:RS_315._col1=RS_1697._col0(Inner),Output:["_col5","_col6","_col7"] + <-Map 63 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1697] PartitionCols:_col0 - Select Operator [SEL_1104] (rows=462000 width=1436) + Select Operator [SEL_1681] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_1095] (rows=462000 width=1436) + Filter Operator [FIL_1672] (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] + <-Reducer 104 [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] + Merge Join Operator [MERGEJOIN_1409] (rows=316788826 width=135) + Conds:RS_1877._col0=RS_1614._col0(Inner),Output:["_col1"] + <-Map 102 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1614] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1064] - <-Map 89 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1224] + Please refer to the previous Select Operator [SEL_1611] + <-Map 110 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1877] PartitionCols:_col0 - Select Operator [SEL_1223] (rows=287989836 width=135) + Select Operator [SEL_1876] (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) + Filter Operator [FIL_1875] (rows=287989836 width=135) + predicate:((cs_item_sk BETWEEN DynamicValue(RS_127_ics_i_item_sk_min) AND DynamicValue(RS_127_ics_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_127_ics_i_item_sk_bloom_filter))) and (cs_sold_date_sk BETWEEN DynamicValue(RS_124_d2_d_date_sk_min) AND DynamicValue(RS_124_d2_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_124_d2_d_date_sk_bloom_filter))) and 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] + <-Reducer 105 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1872] + Group By Operator [GBY_1871] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 102 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1632] + Group By Operator [GBY_1627] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1615] (rows=8116 width=1119) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1611] + <-Reducer 74 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1874] + Group By Operator [GBY_1873] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 63 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1711] + Group By Operator [GBY_1705] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1690] (rows=462000 width=1436) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1677] + <-Reducer 96 [CONTAINS] vectorized + Reduce Output Operator [RS_1905] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_1247] (rows=609832849 width=108) + Group By Operator [GBY_1904] (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) + Group By Operator [GBY_1903] (rows=87121617 width=135) Output:["_col0","_col1","_col2","_col3"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2 - <-Reducer 81 [SIMPLE_EDGE] + <-Reducer 95 [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] + Merge Join Operator [MERGEJOIN_1427] (rows=174243235 width=135) + Conds:RS_336._col1=RS_1698._col0(Inner),Output:["_col5","_col6","_col7"] + <-Map 63 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1698] PartitionCols:_col0 - Select Operator [SEL_1105] (rows=462000 width=1436) + Select Operator [SEL_1682] (rows=462000 width=1436) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_1096] (rows=462000 width=1436) + Filter Operator [FIL_1673] (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] + <-Reducer 106 [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] + Merge Join Operator [MERGEJOIN_1411] (rows=158402938 width=135) + Conds:RS_1887._col0=RS_1616._col0(Inner),Output:["_col1"] + <-Map 102 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1616] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1064] - <-Map 90 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1230] + Please refer to the previous Select Operator [SEL_1611] + <-Map 111 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1887] PartitionCols:_col0 - Select Operator [SEL_1229] (rows=144002668 width=135) + Select Operator [SEL_1886] (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) + Filter Operator [FIL_1885] (rows=144002668 width=135) + predicate:((ws_item_sk BETWEEN DynamicValue(RS_148_iws_i_item_sk_min) AND DynamicValue(RS_148_iws_i_item_sk_max) and in_bloom_filter(ws_item_sk, DynamicValue(RS_148_iws_i_item_sk_bloom_filter))) and (ws_sold_date_sk BETWEEN DynamicValue(RS_145_d3_d_date_sk_min) AND DynamicValue(RS_145_d3_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_145_d3_d_date_sk_bloom_filter))) and 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 107 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1882] + Group By Operator [GBY_1881] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 102 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1633] + Group By Operator [GBY_1628] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1617] (rows=8116 width=1119) +
<TRUNCATED>
