Repository: hive Updated Branches: refs/heads/master 9f2e8e61f -> 83d1fd23a
http://git-wip-us.apache.org/repos/asf/hive/blob/83d1fd23/ql/src/test/results/clientpositive/perf/tez/constraints/query95.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/constraints/query95.q.out b/ql/src/test/results/clientpositive/perf/tez/constraints/query95.q.out index 0b0c9c5..523fa2c 100644 --- a/ql/src/test/results/clientpositive/perf/tez/constraints/query95.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/constraints/query95.q.out @@ -75,18 +75,24 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### Plan optimized by CBO. Vertex dependency in root stage -Map 1 <- Reducer 13 (BROADCAST_EDGE) -Map 15 <- Reducer 10 (BROADCAST_EDGE) -Map 18 <- Reducer 10 (BROADCAST_EDGE) -Reducer 10 <- Reducer 4 (CUSTOM_SIMPLE_EDGE) -Reducer 13 <- Map 12 (CUSTOM_SIMPLE_EDGE) -Reducer 16 <- Map 15 (SIMPLE_EDGE), Map 18 (SIMPLE_EDGE) -Reducer 17 <- Map 19 (SIMPLE_EDGE), Reducer 16 (ONE_TO_ONE_EDGE) -Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 11 (SIMPLE_EDGE) -Reducer 3 <- Map 12 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE) -Reducer 4 <- Map 14 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE) -Reducer 5 <- Reducer 16 (ONE_TO_ONE_EDGE), Reducer 4 (SIMPLE_EDGE) -Reducer 6 <- Reducer 17 (ONE_TO_ONE_EDGE), Reducer 5 (ONE_TO_ONE_EDGE) +Map 1 <- Reducer 14 (BROADCAST_EDGE) +Map 16 <- Reducer 11 (BROADCAST_EDGE) +Map 19 <- Reducer 11 (BROADCAST_EDGE) +Map 20 <- Reducer 10 (BROADCAST_EDGE) +Map 24 <- Reducer 10 (BROADCAST_EDGE) +Reducer 10 <- Reducer 5 (CUSTOM_SIMPLE_EDGE) +Reducer 11 <- Reducer 4 (CUSTOM_SIMPLE_EDGE) +Reducer 14 <- Map 13 (CUSTOM_SIMPLE_EDGE) +Reducer 17 <- Map 16 (SIMPLE_EDGE), Map 19 (SIMPLE_EDGE) +Reducer 18 <- Reducer 17 (SIMPLE_EDGE) +Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 12 (SIMPLE_EDGE) +Reducer 21 <- Map 20 (SIMPLE_EDGE), Map 24 (SIMPLE_EDGE) +Reducer 22 <- Map 25 (SIMPLE_EDGE), Reducer 21 (ONE_TO_ONE_EDGE) +Reducer 23 <- Reducer 22 (SIMPLE_EDGE) +Reducer 3 <- Map 13 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE) +Reducer 4 <- Map 15 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE) +Reducer 5 <- Reducer 18 (ONE_TO_ONE_EDGE), Reducer 4 (SIMPLE_EDGE) +Reducer 6 <- Reducer 23 (ONE_TO_ONE_EDGE), Reducer 5 (ONE_TO_ONE_EDGE) Reducer 7 <- Reducer 6 (SIMPLE_EDGE) Reducer 8 <- Reducer 7 (CUSTOM_SIMPLE_EDGE) Reducer 9 <- Reducer 8 (SIMPLE_EDGE) @@ -96,152 +102,201 @@ Stage-0 limit:-1 Stage-1 Reducer 9 vectorized - File Output Operator [FS_263] - Limit [LIM_262] (rows=1 width=240) + File Output Operator [FS_284] + Limit [LIM_283] (rows=1 width=240) Number of rows:100 - Select Operator [SEL_261] (rows=1 width=240) + Select Operator [SEL_282] (rows=1 width=240) Output:["_col0","_col1","_col2"] <-Reducer 8 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_260] - Select Operator [SEL_259] (rows=1 width=240) + SHUFFLE [RS_281] + Select Operator [SEL_280] (rows=1 width=240) Output:["_col1","_col2","_col3"] - Group By Operator [GBY_258] (rows=1 width=232) + Group By Operator [GBY_279] (rows=1 width=232) Output:["_col0","_col1","_col2"],aggregations:["count(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)"] <-Reducer 7 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_257] - Group By Operator [GBY_256] (rows=1 width=232) + PARTITION_ONLY_SHUFFLE [RS_278] + Group By Operator [GBY_277] (rows=1 width=232) Output:["_col0","_col1","_col2"],aggregations:["count(_col0)","sum(_col1)","sum(_col2)"] - Group By Operator [GBY_255] (rows=38111880083 width=228) + Group By Operator [GBY_276] (rows=2511437 width=228) Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0 <-Reducer 6 [SIMPLE_EDGE] - SHUFFLE [RS_101] + SHUFFLE [RS_109] PartitionCols:_col0 - Group By Operator [GBY_100] (rows=38111880083 width=228) + Group By Operator [GBY_108] (rows=2511437 width=228) Output:["_col0","_col2","_col3"],aggregations:["sum(_col4)","sum(_col5)"],keys:_col3 - Merge Join Operator [MERGEJOIN_227] (rows=83469759007 width=227) - Conds:RS_47._col3=RS_48._col0(Inner),Output:["_col3","_col4","_col5"] - <-Reducer 17 [ONE_TO_ONE_EDGE] - FORWARD [RS_48] - PartitionCols:_col0 - Select Operator [SEL_34] (rows=1384229738 width=4) - Output:["_col0"] - Merge Join Operator [MERGEJOIN_221] (rows=1384229738 width=4) - Conds:RS_31._col0=RS_254.wr_order_number(Inner),Output:["_col14"] - <-Reducer 16 [ONE_TO_ONE_EDGE] - FORWARD [RS_31] - PartitionCols:_col0 - Select Operator [SEL_29] (rows=1411940834 width=4) - Output:["_col0"] - Filter Operator [FIL_28] (rows=1411940834 width=11) - predicate:(_col0 <> _col2) - Merge Join Operator [MERGEJOIN_220] (rows=1411940834 width=11) - Conds:RS_250._col1=RS_253._col1(Inner),Output:["_col0","_col1","_col2"] - <-Map 15 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_250] - PartitionCols:_col1 - Select Operator [SEL_249] (rows=144002668 width=7) - Output:["_col0","_col1"] - Filter Operator [FIL_248] (rows=144002668 width=7) - predicate:(in_bloom_filter(ws_order_number, DynamicValue(RS_44_ws1_ws_order_number_bloom_filter)) and ws_order_number BETWEEN DynamicValue(RS_44_ws1_ws_order_number_min) AND DynamicValue(RS_44_ws1_ws_order_number_max)) - TableScan [TS_21] (rows=144002668 width=7) - default@web_sales,ws1,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_warehouse_sk","ws_order_number"] - <-Reducer 10 [BROADCAST_EDGE] vectorized - BROADCAST [RS_246] - Group By Operator [GBY_245] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Reducer 4 [CUSTOM_SIMPLE_EDGE] - SHUFFLE [RS_179] - Group By Operator [GBY_178] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_177] (rows=5022875 width=8) - Output:["_col0"] - Merge Join Operator [MERGEJOIN_224] (rows=5022875 width=227) - Conds:RS_41._col2=RS_244._col0(Inner),Output:["_col3","_col4","_col5"] - <-Map 14 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_244] - PartitionCols:_col0 - Select Operator [SEL_243] (rows=12 width=4) - Output:["_col0"] - Filter Operator [FIL_242] (rows=12 width=92) - predicate:(web_company_name = 'pri') - TableScan [TS_9] (rows=84 width=92) - default@web_site,web_site,Tbl:COMPLETE,Col:COMPLETE,Output:["web_site_sk","web_company_name"] - <-Reducer 3 [SIMPLE_EDGE] - SHUFFLE [RS_41] - PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_223] (rows=15673790 width=231) - Conds:RS_38._col1=RS_230._col0(Inner),Output:["_col2","_col3","_col4","_col5"] - <-Map 12 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_230] - PartitionCols:_col0 - Select Operator [SEL_229] (rows=784314 width=4) - Output:["_col0"] - Filter Operator [FIL_228] (rows=784314 width=90) - predicate:(ca_state = 'TX') - TableScan [TS_6] (rows=40000000 width=90) - default@customer_address,customer_address,Tbl:COMPLETE,Col:COMPLETE,Output:["ca_address_sk","ca_state"] - <-Reducer 2 [SIMPLE_EDGE] - SHUFFLE [RS_38] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_222] (rows=15987241 width=235) - Conds:RS_238._col0=RS_241._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_238] - PartitionCols:_col0 - Select Operator [SEL_237] (rows=143895019 width=239) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_236] (rows=143895019 width=239) - predicate:((ws_ship_addr_sk BETWEEN DynamicValue(RS_39_customer_address_ca_address_sk_min) AND DynamicValue(RS_39_customer_address_ca_address_sk_max) and in_bloom_filter(ws_ship_addr_sk, DynamicValue(RS_39_customer_address_ca_address_sk_bloom_filter))) and ws_ship_addr_sk is not null and ws_ship_date_sk is not null and ws_web_site_sk is not null) - TableScan [TS_0] (rows=144002668 width=239) - default@web_sales,ws1,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_ship_date_sk","ws_ship_addr_sk","ws_web_site_sk","ws_order_number","ws_ext_ship_cost","ws_net_profit"] - <-Reducer 13 [BROADCAST_EDGE] vectorized - BROADCAST [RS_235] - Group By Operator [GBY_234] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 12 [CUSTOM_SIMPLE_EDGE] vectorized - SHUFFLE [RS_233] - Group By Operator [GBY_232] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_231] (rows=784314 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_229] - <-Map 11 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_241] - PartitionCols:_col0 - Select Operator [SEL_240] (rows=8116 width=98) - Output:["_col0"] - Filter Operator [FIL_239] (rows=8116 width=98) - predicate:CAST( d_date AS TIMESTAMP) BETWEEN TIMESTAMP'1999-05-01 00:00:00' AND TIMESTAMP'1999-06-30 00:00:00' - TableScan [TS_3] (rows=73049 width=98) - default@date_dim,date_dim,Tbl:COMPLETE,Col:COMPLETE,Output:["d_date_sk","d_date"] - <-Map 18 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_253] - PartitionCols:_col1 - Select Operator [SEL_252] (rows=144002668 width=7) - Output:["_col0","_col1"] - Filter Operator [FIL_251] (rows=144002668 width=7) - predicate:(in_bloom_filter(ws_order_number, DynamicValue(RS_44_ws1_ws_order_number_bloom_filter)) and ws_order_number BETWEEN DynamicValue(RS_44_ws1_ws_order_number_min) AND DynamicValue(RS_44_ws1_ws_order_number_max)) - TableScan [TS_23] (rows=144002668 width=7) - default@web_sales,ws2,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_warehouse_sk","ws_order_number"] - <-Reducer 10 [BROADCAST_EDGE] vectorized - BROADCAST [RS_247] - Please refer to the previous Group By Operator [GBY_245] - <-Map 19 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_254] - PartitionCols:wr_order_number - TableScan [TS_30] (rows=14398467 width=4) - default@web_returns,web_returns,Tbl:COMPLETE,Col:COMPLETE,Output:["wr_order_number"] + Merge Join Operator [MERGEJOIN_235] (rows=5022875 width=227) + Conds:RS_55._col3=RS_275._col0(Inner),Output:["_col3","_col4","_col5"] <-Reducer 5 [ONE_TO_ONE_EDGE] - FORWARD [RS_47] + FORWARD [RS_55] PartitionCols:_col3 - Merge Join Operator [MERGEJOIN_226] (rows=482885639 width=227) - Conds:RS_44._col3=RS_45._col0(Inner),Output:["_col3","_col4","_col5"] - <-Reducer 16 [ONE_TO_ONE_EDGE] - FORWARD [RS_45] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_29] + Merge Join Operator [MERGEJOIN_234] (rows=5022875 width=227) + Conds:RS_52._col3=RS_263._col0(Inner),Output:["_col3","_col4","_col5"] <-Reducer 4 [SIMPLE_EDGE] - SHUFFLE [RS_44] + SHUFFLE [RS_52] PartitionCols:_col3 - Please refer to the previous Merge Join Operator [MERGEJOIN_224] + Merge Join Operator [MERGEJOIN_232] (rows=5022875 width=227) + Conds:RS_49._col2=RS_252._col0(Inner),Output:["_col3","_col4","_col5"] + <-Map 15 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_252] + PartitionCols:_col0 + Select Operator [SEL_251] (rows=12 width=4) + Output:["_col0"] + Filter Operator [FIL_250] (rows=12 width=92) + predicate:(web_company_name = 'pri') + TableScan [TS_9] (rows=84 width=92) + default@web_site,web_site,Tbl:COMPLETE,Col:COMPLETE,Output:["web_site_sk","web_company_name"] + <-Reducer 3 [SIMPLE_EDGE] + SHUFFLE [RS_49] + PartitionCols:_col2 + Merge Join Operator [MERGEJOIN_231] (rows=15673790 width=231) + Conds:RS_46._col1=RS_238._col0(Inner),Output:["_col2","_col3","_col4","_col5"] + <-Map 13 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_238] + PartitionCols:_col0 + Select Operator [SEL_237] (rows=784314 width=4) + Output:["_col0"] + Filter Operator [FIL_236] (rows=784314 width=90) + predicate:(ca_state = 'TX') + TableScan [TS_6] (rows=40000000 width=90) + default@customer_address,customer_address,Tbl:COMPLETE,Col:COMPLETE,Output:["ca_address_sk","ca_state"] + <-Reducer 2 [SIMPLE_EDGE] + SHUFFLE [RS_46] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_230] (rows=15987241 width=235) + Conds:RS_246._col0=RS_249._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] + <-Map 1 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_246] + PartitionCols:_col0 + Select Operator [SEL_245] (rows=143895019 width=239) + Output:["_col0","_col1","_col2","_col3","_col4","_col5"] + Filter Operator [FIL_244] (rows=143895019 width=239) + predicate:((ws_ship_addr_sk BETWEEN DynamicValue(RS_47_customer_address_ca_address_sk_min) AND DynamicValue(RS_47_customer_address_ca_address_sk_max) and in_bloom_filter(ws_ship_addr_sk, DynamicValue(RS_47_customer_address_ca_address_sk_bloom_filter))) and ws_ship_addr_sk is not null and ws_ship_date_sk is not null and ws_web_site_sk is not null) + TableScan [TS_0] (rows=144002668 width=239) + default@web_sales,ws1,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_ship_date_sk","ws_ship_addr_sk","ws_web_site_sk","ws_order_number","ws_ext_ship_cost","ws_net_profit"] + <-Reducer 14 [BROADCAST_EDGE] vectorized + BROADCAST [RS_243] + Group By Operator [GBY_242] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 13 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_241] + Group By Operator [GBY_240] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_239] (rows=784314 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_237] + <-Map 12 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_249] + PartitionCols:_col0 + Select Operator [SEL_248] (rows=8116 width=98) + Output:["_col0"] + Filter Operator [FIL_247] (rows=8116 width=98) + predicate:CAST( d_date AS TIMESTAMP) BETWEEN TIMESTAMP'1999-05-01 00:00:00' AND TIMESTAMP'1999-06-30 00:00:00' + TableScan [TS_3] (rows=73049 width=98) + default@date_dim,date_dim,Tbl:COMPLETE,Col:COMPLETE,Output:["d_date_sk","d_date"] + <-Reducer 18 [ONE_TO_ONE_EDGE] vectorized + FORWARD [RS_263] + PartitionCols:_col0 + Group By Operator [GBY_262] (rows=14686712 width=4) + Output:["_col0"],keys:KEY._col0 + <-Reducer 17 [SIMPLE_EDGE] + SHUFFLE [RS_22] + PartitionCols:_col0 + Group By Operator [GBY_21] (rows=144002668 width=4) + Output:["_col0"],keys:_col1 + Select Operator [SEL_20] (rows=1411940834 width=11) + Output:["_col1"] + Filter Operator [FIL_19] (rows=1411940834 width=11) + predicate:(_col0 <> _col2) + Merge Join Operator [MERGEJOIN_233] (rows=1411940834 width=11) + Conds:RS_258._col1=RS_261._col1(Inner),Output:["_col0","_col1","_col2"] + <-Map 16 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_258] + PartitionCols:_col1 + Select Operator [SEL_257] (rows=144002668 width=7) + Output:["_col0","_col1"] + Filter Operator [FIL_256] (rows=144002668 width=7) + predicate:(in_bloom_filter(ws_order_number, DynamicValue(RS_52_ws1_ws_order_number_bloom_filter)) and ws_order_number BETWEEN DynamicValue(RS_52_ws1_ws_order_number_min) AND DynamicValue(RS_52_ws1_ws_order_number_max)) + TableScan [TS_12] (rows=144002668 width=7) + default@web_sales,ws1,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_warehouse_sk","ws_order_number"] + <-Reducer 11 [BROADCAST_EDGE] vectorized + BROADCAST [RS_254] + Group By Operator [GBY_253] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Reducer 4 [CUSTOM_SIMPLE_EDGE] + SHUFFLE [RS_187] + Group By Operator [GBY_186] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_185] (rows=5022875 width=8) + Output:["_col0"] + Please refer to the previous Merge Join Operator [MERGEJOIN_232] + <-Map 19 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_261] + PartitionCols:_col1 + Select Operator [SEL_260] (rows=144002668 width=7) + Output:["_col0","_col1"] + Filter Operator [FIL_259] (rows=144002668 width=7) + predicate:(in_bloom_filter(ws_order_number, DynamicValue(RS_52_ws1_ws_order_number_bloom_filter)) and ws_order_number BETWEEN DynamicValue(RS_52_ws1_ws_order_number_min) AND DynamicValue(RS_52_ws1_ws_order_number_max)) + TableScan [TS_14] (rows=144002668 width=7) + default@web_sales,ws2,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_warehouse_sk","ws_order_number"] + <-Reducer 11 [BROADCAST_EDGE] vectorized + BROADCAST [RS_255] + Please refer to the previous Group By Operator [GBY_253] + <-Reducer 23 [ONE_TO_ONE_EDGE] vectorized + FORWARD [RS_275] + PartitionCols:_col0 + Group By Operator [GBY_274] (rows=8007986 width=4) + Output:["_col0"],keys:KEY._col0 + <-Reducer 22 [SIMPLE_EDGE] + SHUFFLE [RS_40] + PartitionCols:_col0 + Group By Operator [GBY_39] (rows=14398467 width=4) + Output:["_col0"],keys:_col14 + Merge Join Operator [MERGEJOIN_229] (rows=1384229738 width=4) + Conds:RS_35._col0=RS_273.wr_order_number(Inner),Output:["_col14"] + <-Map 25 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_273] + PartitionCols:wr_order_number + TableScan [TS_34] (rows=14398467 width=4) + default@web_returns,web_returns,Tbl:COMPLETE,Col:COMPLETE,Output:["wr_order_number"] + <-Reducer 21 [ONE_TO_ONE_EDGE] + FORWARD [RS_35] + PartitionCols:_col0 + Select Operator [SEL_33] (rows=1411940834 width=4) + Output:["_col0"] + Filter Operator [FIL_32] (rows=1411940834 width=11) + predicate:(_col0 <> _col2) + Merge Join Operator [MERGEJOIN_228] (rows=1411940834 width=11) + Conds:RS_269._col1=RS_272._col1(Inner),Output:["_col0","_col1","_col2"] + <-Map 20 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_269] + PartitionCols:_col1 + Select Operator [SEL_268] (rows=144002668 width=7) + Output:["_col0","_col1"] + Filter Operator [FIL_267] (rows=144002668 width=7) + predicate:(in_bloom_filter(ws_order_number, DynamicValue(RS_55_ws1_ws_order_number_bloom_filter)) and ws_order_number BETWEEN DynamicValue(RS_55_ws1_ws_order_number_min) AND DynamicValue(RS_55_ws1_ws_order_number_max)) + TableScan [TS_25] (rows=144002668 width=7) + default@web_sales,ws1,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_warehouse_sk","ws_order_number"] + <-Reducer 10 [BROADCAST_EDGE] vectorized + BROADCAST [RS_265] + Group By Operator [GBY_264] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Reducer 5 [CUSTOM_SIMPLE_EDGE] + FORWARD [RS_206] + Group By Operator [GBY_205] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_204] (rows=5022875 width=8) + Output:["_col0"] + Please refer to the previous Merge Join Operator [MERGEJOIN_234] + <-Map 24 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_272] + PartitionCols:_col1 + Select Operator [SEL_271] (rows=144002668 width=7) + Output:["_col0","_col1"] + Filter Operator [FIL_270] (rows=144002668 width=7) + predicate:(in_bloom_filter(ws_order_number, DynamicValue(RS_55_ws1_ws_order_number_bloom_filter)) and ws_order_number BETWEEN DynamicValue(RS_55_ws1_ws_order_number_min) AND DynamicValue(RS_55_ws1_ws_order_number_max)) + TableScan [TS_27] (rows=144002668 width=7) + default@web_sales,ws2,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_warehouse_sk","ws_order_number"] + <-Reducer 10 [BROADCAST_EDGE] vectorized + BROADCAST [RS_266] + Please refer to the previous Group By Operator [GBY_264]
