You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2018/08/07 19:27:00 UTC
[2/3] hive git commit: HIVE-20320: Turn on
hive.optimize.remove.sq_count_check flag (Vineet Garg,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/d4a8625d/ql/src/test/results/clientpositive/perf/tez/query44.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query44.q.out b/ql/src/test/results/clientpositive/perf/tez/query44.q.out
index 0dbce70..8105de9 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query44.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query44.q.out
@@ -1,4 +1,4 @@
-Warning: Shuffle Join MERGEJOIN[141][tables = [$hdt$_2, $hdt$_3, $hdt$_1]] in Stage 'Reducer 9' is a cross product
+Warning: Shuffle Join MERGEJOIN[103][tables = [$hdt$_1, $hdt$_2]] in Stage 'Reducer 8' is a cross product
PREHOOK: query: explain
select asceding.rnk, i1.i_product_name best_performing, i2.i_product_name worst_performing
from(select *
@@ -70,146 +70,120 @@ POSTHOOK: type: QUERY
Plan optimized by CBO.
Vertex dependency in root stage
-Reducer 10 <- Reducer 9 (SIMPLE_EDGE)
-Reducer 11 <- Reducer 9 (SIMPLE_EDGE)
-Reducer 13 <- Map 12 (SIMPLE_EDGE)
-Reducer 15 <- Map 14 (SIMPLE_EDGE)
-Reducer 2 <- Map 1 (SIMPLE_EDGE), Reducer 10 (SIMPLE_EDGE)
+Reducer 10 <- Reducer 8 (SIMPLE_EDGE)
+Reducer 12 <- Map 11 (SIMPLE_EDGE)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
Reducer 3 <- Reducer 2 (SIMPLE_EDGE), Reducer 5 (SIMPLE_EDGE)
Reducer 4 <- Reducer 3 (SIMPLE_EDGE)
-Reducer 5 <- Map 1 (SIMPLE_EDGE), Reducer 11 (SIMPLE_EDGE)
+Reducer 5 <- Map 1 (SIMPLE_EDGE), Reducer 10 (SIMPLE_EDGE)
Reducer 7 <- Map 6 (SIMPLE_EDGE)
-Reducer 8 <- Reducer 7 (CUSTOM_SIMPLE_EDGE)
-Reducer 9 <- Reducer 13 (CUSTOM_SIMPLE_EDGE), Reducer 15 (CUSTOM_SIMPLE_EDGE), Reducer 8 (CUSTOM_SIMPLE_EDGE)
+Reducer 8 <- Reducer 12 (CUSTOM_SIMPLE_EDGE), Reducer 7 (CUSTOM_SIMPLE_EDGE)
+Reducer 9 <- Reducer 8 (SIMPLE_EDGE)
Stage-0
Fetch Operator
limit:100
Stage-1
Reducer 4 vectorized
- File Output Operator [FS_188]
- Limit [LIM_187] (rows=100 width=185)
+ File Output Operator [FS_138]
+ Limit [LIM_137] (rows=100 width=177)
Number of rows:100
- Select Operator [SEL_186] (rows=1393898919384048 width=185)
+ Select Operator [SEL_136] (rows=1393898919384048 width=177)
Output:["_col0","_col1","_col2"]
<-Reducer 3 [SIMPLE_EDGE]
- SHUFFLE [RS_101]
- Select Operator [SEL_100] (rows=1393898919384048 width=185)
+ SHUFFLE [RS_69]
+ Select Operator [SEL_68] (rows=1393898919384048 width=177)
Output:["_col0","_col1","_col2"]
- Merge Join Operator [MERGEJOIN_145] (rows=1393898919384048 width=185)
- Conds:RS_97._col3=RS_98._col3(Inner),Output:["_col1","_col3","_col5"]
+ Merge Join Operator [MERGEJOIN_107] (rows=1393898919384048 width=177)
+ Conds:RS_65._col3=RS_66._col3(Inner),Output:["_col1","_col3","_col5"]
<-Reducer 2 [SIMPLE_EDGE]
- SHUFFLE [RS_97]
+ SHUFFLE [RS_65]
PartitionCols:_col3
- Merge Join Operator [MERGEJOIN_142] (rows=1267180808338276 width=185)
- Conds:RS_148._col0=RS_180._col0(Inner),Output:["_col1","_col3"]
+ Merge Join Operator [MERGEJOIN_104] (rows=1267180808338276 width=177)
+ Conds:RS_110._col0=RS_130._col0(Inner),Output:["_col1","_col3"]
<-Map 1 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_148]
+ SHUFFLE [RS_110]
PartitionCols:_col0
- Select Operator [SEL_147] (rows=462000 width=1436)
+ Select Operator [SEL_109] (rows=462000 width=1436)
Output:["_col0","_col1"]
- Filter Operator [FIL_146] (rows=462000 width=1436)
+ Filter Operator [FIL_108] (rows=462000 width=1436)
predicate:i_item_sk is not null
TableScan [TS_0] (rows=462000 width=1436)
default@item,i1,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_product_name"]
- <-Reducer 10 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_180]
+ <-Reducer 9 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_130]
PartitionCols:_col0
- Select Operator [SEL_179] (rows=1151982528066248 width=185)
+ Select Operator [SEL_129] (rows=1151982528066248 width=177)
Output:["_col0","_col1"]
- Filter Operator [FIL_178] (rows=1151982528066248 width=185)
- predicate:((rank_window_0 < 11) and _col2 is not null)
- PTF Operator [PTF_177] (rows=3455947584198744 width=185)
- Function definitions:[{},{"name:":"windowingtablefunction","order by:":"_col3 ASC NULLS FIRST","partition by:":"0"}]
- Select Operator [SEL_176] (rows=3455947584198744 width=185)
- Output:["_col2","_col3"]
- <-Reducer 9 [SIMPLE_EDGE]
- SHUFFLE [RS_38]
+ Filter Operator [FIL_128] (rows=1151982528066248 width=177)
+ predicate:((rank_window_0 < 11) and _col0 is not null)
+ PTF Operator [PTF_127] (rows=3455947584198744 width=177)
+ Function definitions:[{},{"name:":"windowingtablefunction","order by:":"_col1 ASC NULLS FIRST","partition by:":"0"}]
+ Select Operator [SEL_126] (rows=3455947584198744 width=177)
+ Output:["_col0","_col1"]
+ <-Reducer 8 [SIMPLE_EDGE]
+ SHUFFLE [RS_22]
PartitionCols:0
- Filter Operator [FIL_37] (rows=3455947584198744 width=185)
- predicate:(_col3 > (0.9 * _col1))
- Merge Join Operator [MERGEJOIN_141] (rows=10367842752596232 width=185)
- Conds:(Inner),(Inner),Output:["_col1","_col2","_col3"]
- <-Reducer 13 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_168]
- Select Operator [SEL_167] (rows=71999454 width=88)
+ Filter Operator [FIL_21] (rows=3455947584198744 width=177)
+ predicate:(_col1 > (0.9 * _col2))
+ Merge Join Operator [MERGEJOIN_103] (rows=10367842752596232 width=177)
+ Conds:(Inner),Output:["_col0","_col1","_col2"]
+ <-Reducer 12 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_125]
+ Select Operator [SEL_124] (rows=71999454 width=88)
Output:["_col0"]
- Group By Operator [GBY_166] (rows=71999454 width=88)
+ Group By Operator [GBY_123] (rows=71999454 width=88)
Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"],keys:KEY._col0
- <-Map 12 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_165]
+ <-Map 11 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_122]
PartitionCols:_col0
- Group By Operator [GBY_164] (rows=143998908 width=88)
+ Group By Operator [GBY_121] (rows=143998908 width=88)
Output:["_col0","_col1","_col2"],aggregations:["sum(_col1)","count(_col1)"],keys:410
- Select Operator [SEL_163] (rows=143998908 width=88)
+ Select Operator [SEL_120] (rows=143998908 width=88)
Output:["_col1"]
- Filter Operator [FIL_162] (rows=143998908 width=88)
+ Filter Operator [FIL_119] (rows=143998908 width=88)
predicate:((ss_store_sk = 410) and ss_hdemo_sk is null)
- TableScan [TS_18] (rows=575995635 width=88)
+ TableScan [TS_10] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_hdemo_sk","ss_store_sk","ss_net_profit"]
- <-Reducer 15 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_175]
- Select Operator [SEL_174] (rows=143998908 width=88)
+ <-Reducer 7 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_118]
+ Select Operator [SEL_117] (rows=143998908 width=88)
Output:["_col0","_col1"]
- Group By Operator [GBY_173] (rows=143998908 width=88)
+ Group By Operator [GBY_116] (rows=143998908 width=88)
Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)"],keys:KEY._col0
- <-Map 14 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_172]
+ <-Map 6 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_115]
PartitionCols:_col0
- Group By Operator [GBY_171] (rows=287997817 width=88)
+ Group By Operator [GBY_114] (rows=287997817 width=88)
Output:["_col0","_col1","_col2"],aggregations:["sum(ss_net_profit)","count(ss_net_profit)"],keys:ss_item_sk
- Select Operator [SEL_170] (rows=287997817 width=88)
+ Select Operator [SEL_113] (rows=287997817 width=88)
Output:["ss_item_sk","ss_net_profit"]
- Filter Operator [FIL_169] (rows=287997817 width=88)
+ Filter Operator [FIL_112] (rows=287997817 width=88)
predicate:(ss_store_sk = 410)
- TableScan [TS_26] (rows=575995635 width=88)
+ TableScan [TS_3] (rows=575995635 width=88)
default@store_sales,ss1,Tbl:COMPLETE,Col:NONE,Output:["ss_item_sk","ss_store_sk","ss_net_profit"]
- <-Reducer 8 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_161]
- Select Operator [SEL_160] (rows=1 width=8)
- Filter Operator [FIL_159] (rows=1 width=8)
- predicate:(sq_count_check(_col0) <= 1)
- Group By Operator [GBY_158] (rows=1 width=8)
- Output:["_col0"],aggregations:["count(VALUE._col0)"]
- <-Reducer 7 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_157]
- Group By Operator [GBY_156] (rows=1 width=8)
- Output:["_col0"],aggregations:["count()"]
- Select Operator [SEL_155] (rows=71999454 width=88)
- Group By Operator [GBY_154] (rows=71999454 width=88)
- Output:["_col0"],keys:KEY._col0
- <-Map 6 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_153]
- PartitionCols:_col0
- Group By Operator [GBY_152] (rows=143998908 width=88)
- Output:["_col0"],keys:410
- Select Operator [SEL_151] (rows=143998908 width=88)
- Filter Operator [FIL_150] (rows=143998908 width=88)
- predicate:((ss_store_sk = 410) and ss_hdemo_sk is null)
- TableScan [TS_3] (rows=575995635 width=88)
- default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_hdemo_sk","ss_store_sk"]
<-Reducer 5 [SIMPLE_EDGE]
- SHUFFLE [RS_98]
+ SHUFFLE [RS_66]
PartitionCols:_col3
- Merge Join Operator [MERGEJOIN_144] (rows=1267180808338276 width=185)
- Conds:RS_149._col0=RS_185._col0(Inner),Output:["_col1","_col3"]
+ Merge Join Operator [MERGEJOIN_106] (rows=1267180808338276 width=177)
+ Conds:RS_111._col0=RS_135._col0(Inner),Output:["_col1","_col3"]
<-Map 1 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_149]
+ SHUFFLE [RS_111]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_147]
- <-Reducer 11 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_185]
+ Please refer to the previous Select Operator [SEL_109]
+ <-Reducer 10 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_135]
PartitionCols:_col0
- Select Operator [SEL_184] (rows=1151982528066248 width=185)
+ Select Operator [SEL_134] (rows=1151982528066248 width=177)
Output:["_col0","_col1"]
- Filter Operator [FIL_183] (rows=1151982528066248 width=185)
- predicate:((rank_window_0 < 11) and _col2 is not null)
- PTF Operator [PTF_182] (rows=3455947584198744 width=185)
- Function definitions:[{},{"name:":"windowingtablefunction","order by:":"_col3 DESC NULLS LAST","partition by:":"0"}]
- Select Operator [SEL_181] (rows=3455947584198744 width=185)
- Output:["_col2","_col3"]
- <-Reducer 9 [SIMPLE_EDGE]
- SHUFFLE [RS_83]
+ Filter Operator [FIL_133] (rows=1151982528066248 width=177)
+ predicate:((rank_window_0 < 11) and _col0 is not null)
+ PTF Operator [PTF_132] (rows=3455947584198744 width=177)
+ Function definitions:[{},{"name:":"windowingtablefunction","order by:":"_col1 DESC NULLS LAST","partition by:":"0"}]
+ Select Operator [SEL_131] (rows=3455947584198744 width=177)
+ Output:["_col0","_col1"]
+ <-Reducer 8 [SIMPLE_EDGE]
+ SHUFFLE [RS_51]
PartitionCols:0
- Please refer to the previous Filter Operator [FIL_37]
+ Please refer to the previous Filter Operator [FIL_21]
http://git-wip-us.apache.org/repos/asf/hive/blob/d4a8625d/ql/src/test/results/clientpositive/perf/tez/query54.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query54.q.out b/ql/src/test/results/clientpositive/perf/tez/query54.q.out
index 3e3c607..c889ce1 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query54.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query54.q.out
@@ -1,7 +1,7 @@
-Warning: Shuffle Join MERGEJOIN[271][tables = [$hdt$_0, $hdt$_1, $hdt$_2, $hdt$_3]] in Stage 'Reducer 4' is a cross product
-Warning: Shuffle Join MERGEJOIN[272][tables = [$hdt$_0, $hdt$_1, $hdt$_2, $hdt$_3, $hdt$_4]] in Stage 'Reducer 5' is a cross product
-Warning: Shuffle Join MERGEJOIN[270][tables = [$hdt$_1, $hdt$_2]] in Stage 'Reducer 33' is a cross product
-Warning: Shuffle Join MERGEJOIN[273][tables = [$hdt$_1, $hdt$_2, $hdt$_0]] in Stage 'Reducer 6' is a cross product
+Warning: Shuffle Join MERGEJOIN[270][tables = [$hdt$_0, $hdt$_1, $hdt$_2, $hdt$_3]] in Stage 'Reducer 4' is a cross product
+Warning: Shuffle Join MERGEJOIN[271][tables = [$hdt$_0, $hdt$_1, $hdt$_2, $hdt$_3, $hdt$_4]] in Stage 'Reducer 5' is a cross product
+Warning: Shuffle Join MERGEJOIN[272][tables = [$hdt$_0, $hdt$_1]] in Stage 'Reducer 6' is a cross product
+Warning: Shuffle Join MERGEJOIN[273][tables = [$hdt$_0, $hdt$_1]] in Stage 'Reducer 7' is a cross product
PREHOOK: query: explain
with my_customers as (
select distinct c_customer_sk
@@ -115,31 +115,31 @@ POSTHOOK: type: QUERY
Plan optimized by CBO.
Vertex dependency in root stage
-Map 1 <- Reducer 11 (BROADCAST_EDGE)
-Map 16 <- Reducer 24 (BROADCAST_EDGE), Reducer 26 (BROADCAST_EDGE), Reducer 28 (BROADCAST_EDGE), Union 17 (CONTAINS)
-Map 22 <- Reducer 24 (BROADCAST_EDGE), Reducer 26 (BROADCAST_EDGE), Union 17 (CONTAINS)
-Reducer 11 <- Map 10 (CUSTOM_SIMPLE_EDGE)
-Reducer 13 <- Map 12 (SIMPLE_EDGE), Map 15 (SIMPLE_EDGE)
-Reducer 14 <- Reducer 13 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE)
-Reducer 18 <- Map 23 (SIMPLE_EDGE), Union 17 (SIMPLE_EDGE)
-Reducer 19 <- Map 25 (SIMPLE_EDGE), Reducer 18 (SIMPLE_EDGE)
-Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 10 (SIMPLE_EDGE)
-Reducer 20 <- Map 27 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE)
-Reducer 21 <- Reducer 20 (SIMPLE_EDGE)
-Reducer 24 <- Map 23 (CUSTOM_SIMPLE_EDGE)
-Reducer 26 <- Map 25 (CUSTOM_SIMPLE_EDGE)
-Reducer 28 <- Map 27 (CUSTOM_SIMPLE_EDGE)
-Reducer 3 <- Reducer 14 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
-Reducer 30 <- Map 29 (SIMPLE_EDGE)
-Reducer 31 <- Reducer 30 (CUSTOM_SIMPLE_EDGE)
-Reducer 32 <- Map 29 (SIMPLE_EDGE)
-Reducer 33 <- Reducer 32 (CUSTOM_SIMPLE_EDGE), Reducer 35 (CUSTOM_SIMPLE_EDGE)
-Reducer 34 <- Map 29 (SIMPLE_EDGE)
-Reducer 35 <- Reducer 34 (CUSTOM_SIMPLE_EDGE)
-Reducer 4 <- Reducer 3 (CUSTOM_SIMPLE_EDGE), Reducer 31 (CUSTOM_SIMPLE_EDGE)
-Reducer 5 <- Reducer 30 (CUSTOM_SIMPLE_EDGE), Reducer 4 (CUSTOM_SIMPLE_EDGE)
-Reducer 6 <- Reducer 33 (CUSTOM_SIMPLE_EDGE), Reducer 5 (CUSTOM_SIMPLE_EDGE)
-Reducer 7 <- Reducer 6 (SIMPLE_EDGE)
+Map 1 <- Reducer 12 (BROADCAST_EDGE)
+Map 17 <- Reducer 25 (BROADCAST_EDGE), Reducer 27 (BROADCAST_EDGE), Reducer 29 (BROADCAST_EDGE), Union 18 (CONTAINS)
+Map 23 <- Reducer 25 (BROADCAST_EDGE), Reducer 27 (BROADCAST_EDGE), Union 18 (CONTAINS)
+Reducer 10 <- Reducer 9 (SIMPLE_EDGE)
+Reducer 12 <- Map 11 (CUSTOM_SIMPLE_EDGE)
+Reducer 14 <- Map 13 (SIMPLE_EDGE), Map 16 (SIMPLE_EDGE)
+Reducer 15 <- Reducer 14 (SIMPLE_EDGE), Reducer 22 (SIMPLE_EDGE)
+Reducer 19 <- Map 24 (SIMPLE_EDGE), Union 18 (SIMPLE_EDGE)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 11 (SIMPLE_EDGE)
+Reducer 20 <- Map 26 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE)
+Reducer 21 <- Map 28 (SIMPLE_EDGE), Reducer 20 (SIMPLE_EDGE)
+Reducer 22 <- Reducer 21 (SIMPLE_EDGE)
+Reducer 25 <- Map 24 (CUSTOM_SIMPLE_EDGE)
+Reducer 27 <- Map 26 (CUSTOM_SIMPLE_EDGE)
+Reducer 29 <- Map 28 (CUSTOM_SIMPLE_EDGE)
+Reducer 3 <- Reducer 15 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
+Reducer 31 <- Map 30 (SIMPLE_EDGE)
+Reducer 32 <- Reducer 31 (CUSTOM_SIMPLE_EDGE)
+Reducer 33 <- Map 30 (SIMPLE_EDGE)
+Reducer 34 <- Reducer 33 (CUSTOM_SIMPLE_EDGE)
+Reducer 35 <- Map 30 (SIMPLE_EDGE)
+Reducer 4 <- Reducer 3 (CUSTOM_SIMPLE_EDGE), Reducer 32 (CUSTOM_SIMPLE_EDGE)
+Reducer 5 <- Reducer 31 (CUSTOM_SIMPLE_EDGE), Reducer 4 (CUSTOM_SIMPLE_EDGE)
+Reducer 6 <- Reducer 34 (CUSTOM_SIMPLE_EDGE), Reducer 5 (CUSTOM_SIMPLE_EDGE)
+Reducer 7 <- Reducer 35 (CUSTOM_SIMPLE_EDGE), Reducer 6 (CUSTOM_SIMPLE_EDGE)
Reducer 8 <- Reducer 7 (SIMPLE_EDGE)
Reducer 9 <- Reducer 8 (SIMPLE_EDGE)
@@ -147,19 +147,19 @@ Stage-0
Fetch Operator
limit:100
Stage-1
- Reducer 9 vectorized
+ Reducer 10 vectorized
File Output Operator [FS_360]
Limit [LIM_359] (rows=100 width=158)
Number of rows:100
Select Operator [SEL_358] (rows=1614130953450400 width=158)
Output:["_col0","_col1","_col2"]
- <-Reducer 8 [SIMPLE_EDGE] vectorized
+ <-Reducer 9 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_357]
Select Operator [SEL_356] (rows=1614130953450400 width=158)
Output:["_col0","_col1","_col2"]
Group By Operator [GBY_355] (rows=1614130953450400 width=158)
Output:["_col0","_col1"],aggregations:["count(VALUE._col0)"],keys:KEY._col0
- <-Reducer 7 [SIMPLE_EDGE] vectorized
+ <-Reducer 8 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_354]
PartitionCols:_col0
Group By Operator [GBY_353] (rows=3228261906900801 width=158)
@@ -168,268 +168,268 @@ Stage-0
Output:["_col0"]
Group By Operator [GBY_351] (rows=3228261906900801 width=158)
Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0
- <-Reducer 6 [SIMPLE_EDGE]
+ <-Reducer 7 [SIMPLE_EDGE]
SHUFFLE [RS_119]
PartitionCols:_col0
Group By Operator [GBY_118] (rows=6456523813801603 width=158)
- Output:["_col0","_col1"],aggregations:["sum(_col4)"],keys:_col0
+ Output:["_col0","_col1"],aggregations:["sum(_col1)"],keys:_col0
Select Operator [SEL_117] (rows=6456523813801603 width=158)
- Output:["_col0","_col4"]
+ Output:["_col0","_col1"]
Filter Operator [FIL_116] (rows=6456523813801603 width=158)
- predicate:_col11 BETWEEN _col13 AND _col15
- Select Operator [SEL_115] (rows=58108714324214428 width=158)
- Output:["_col0","_col4","_col11","_col13","_col15"]
- Merge Join Operator [MERGEJOIN_273] (rows=58108714324214428 width=158)
- Conds:(Inner),Output:["_col0","_col2","_col6","_col13","_col15"]
- <-Reducer 33 [CUSTOM_SIMPLE_EDGE]
- PARTITION_ONLY_SHUFFLE [RS_112]
- Merge Join Operator [MERGEJOIN_270] (rows=9131 width=1128)
- Conds:(Right Outer),Output:["_col0"]
- <-Reducer 32 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_342]
- Group By Operator [GBY_341] (rows=9131 width=1119)
- Output:["_col0"],keys:KEY._col0
- <-Map 29 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_330]
- PartitionCols:_col0
- Group By Operator [GBY_327] (rows=18262 width=1119)
- Output:["_col0"],keys:_col0
- Select Operator [SEL_324] (rows=18262 width=1119)
- Output:["_col0"]
- Filter Operator [FIL_322] (rows=18262 width=1119)
- predicate:((d_moy = 3) and (d_year = 1999))
- TableScan [TS_73] (rows=73049 width=1119)
- default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_month_seq","d_year","d_moy"]
- <-Reducer 35 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_350]
- Select Operator [SEL_349] (rows=1 width=8)
- Filter Operator [FIL_348] (rows=1 width=8)
+ predicate:_col2 BETWEEN _col3 AND _col4
+ Merge Join Operator [MERGEJOIN_273] (rows=58108714324214428 width=158)
+ Conds:(Left Outer),Output:["_col0","_col1","_col2","_col3","_col4"]
+ <-Reducer 35 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_350]
+ Group By Operator [GBY_349] (rows=9131 width=1119)
+ Output:["_col0"],keys:KEY._col0
+ <-Map 30 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_331]
+ PartitionCols:_col0
+ Group By Operator [GBY_328] (rows=18262 width=1119)
+ Output:["_col0"],keys:_col0
+ Select Operator [SEL_325] (rows=18262 width=1119)
+ Output:["_col0"]
+ Filter Operator [FIL_322] (rows=18262 width=1119)
+ predicate:((d_moy = 3) and (d_year = 1999))
+ TableScan [TS_50] (rows=73049 width=1119)
+ default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_month_seq","d_year","d_moy"]
+ <-Reducer 6 [CUSTOM_SIMPLE_EDGE]
+ PARTITION_ONLY_SHUFFLE [RS_113]
+ Select Operator [SEL_104] (rows=6363893803988 width=1226)
+ Output:["_col0","_col1","_col2","_col3"]
+ Merge Join Operator [MERGEJOIN_272] (rows=6363893803988 width=1226)
+ Conds:(Inner),Output:["_col0","_col4","_col11","_col13"]
+ <-Reducer 34 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_348]
+ Select Operator [SEL_347] (rows=1 width=8)
+ Filter Operator [FIL_346] (rows=1 width=8)
predicate:(sq_count_check(_col0) <= 1)
- Group By Operator [GBY_347] (rows=1 width=8)
+ Group By Operator [GBY_345] (rows=1 width=8)
Output:["_col0"],aggregations:["count(VALUE._col0)"]
- <-Reducer 34 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_346]
- Group By Operator [GBY_345] (rows=1 width=8)
+ <-Reducer 33 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_344]
+ Group By Operator [GBY_343] (rows=1 width=8)
Output:["_col0"],aggregations:["count()"]
- Select Operator [SEL_344] (rows=9131 width=1119)
- Group By Operator [GBY_343] (rows=9131 width=1119)
+ Select Operator [SEL_342] (rows=9131 width=1119)
+ Group By Operator [GBY_341] (rows=9131 width=1119)
Output:["_col0"],keys:KEY._col0
- <-Map 29 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_331]
+ <-Map 30 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_330]
PartitionCols:_col0
- Group By Operator [GBY_328] (rows=18262 width=1119)
+ Group By Operator [GBY_327] (rows=18262 width=1119)
Output:["_col0"],keys:_col0
- Select Operator [SEL_325] (rows=18262 width=1119)
+ Select Operator [SEL_324] (rows=18262 width=1119)
Output:["_col0"]
Please refer to the previous Filter Operator [FIL_322]
- <-Reducer 5 [CUSTOM_SIMPLE_EDGE]
- PARTITION_ONLY_SHUFFLE [RS_113]
- Select Operator [SEL_108] (rows=6363893803988 width=1217)
- Output:["_col0","_col4","_col11","_col13"]
- Merge Join Operator [MERGEJOIN_272] (rows=6363893803988 width=1217)
- Conds:(Left Outer),Output:["_col2","_col4","_col10","_col13"]
- <-Reducer 30 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_334]
- Group By Operator [GBY_332] (rows=9131 width=1119)
- Output:["_col0"],keys:KEY._col0
- <-Map 29 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_329]
- PartitionCols:_col0
- Group By Operator [GBY_326] (rows=18262 width=1119)
- Output:["_col0"],keys:_col0
- Select Operator [SEL_323] (rows=18262 width=1119)
- Output:["_col0"]
- Please refer to the previous Filter Operator [FIL_322]
- <-Reducer 4 [CUSTOM_SIMPLE_EDGE]
- PARTITION_ONLY_SHUFFLE [RS_105]
- Merge Join Operator [MERGEJOIN_271] (rows=696954748 width=97)
- Conds:(Inner),Output:["_col2","_col4","_col10"]
- <-Reducer 3 [CUSTOM_SIMPLE_EDGE]
- PARTITION_ONLY_SHUFFLE [RS_102]
- Merge Join Operator [MERGEJOIN_269] (rows=696954748 width=88)
- Conds:RS_99._col1=RS_100._col5(Inner),Output:["_col2","_col4","_col10"]
- <-Reducer 14 [SIMPLE_EDGE]
- SHUFFLE [RS_100]
- PartitionCols:_col5
- Merge Join Operator [MERGEJOIN_268] (rows=316240138 width=135)
- Conds:RS_69._col0=RS_321._col1(Inner),Output:["_col5"]
- <-Reducer 13 [SIMPLE_EDGE]
- SHUFFLE [RS_69]
- PartitionCols:_col0
- Merge Join Operator [MERGEJOIN_264] (rows=44000000 width=1014)
- Conds:RS_297._col1, _col2=RS_300._col0, _col1(Inner),Output:["_col0"]
- <-Map 12 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_297]
- PartitionCols:_col1, _col2
- Select Operator [SEL_296] (rows=40000000 width=1014)
- Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_295] (rows=40000000 width=1014)
- predicate:(ca_address_sk is not null and ca_county is not null and ca_state is not null)
- TableScan [TS_29] (rows=40000000 width=1014)
- default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_county","ca_state"]
- <-Map 15 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_300]
- PartitionCols:_col0, _col1
- Select Operator [SEL_299] (rows=1704 width=1910)
+ <-Reducer 5 [CUSTOM_SIMPLE_EDGE]
+ PARTITION_ONLY_SHUFFLE [RS_101]
+ Select Operator [SEL_85] (rows=6363893803988 width=1217)
+ Output:["_col0","_col4","_col11","_col13"]
+ Merge Join Operator [MERGEJOIN_271] (rows=6363893803988 width=1217)
+ Conds:(Left Outer),Output:["_col2","_col4","_col10","_col13"]
+ <-Reducer 31 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_334]
+ Group By Operator [GBY_332] (rows=9131 width=1119)
+ Output:["_col0"],keys:KEY._col0
+ <-Map 30 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_329]
+ PartitionCols:_col0
+ Group By Operator [GBY_326] (rows=18262 width=1119)
+ Output:["_col0"],keys:_col0
+ Select Operator [SEL_323] (rows=18262 width=1119)
+ Output:["_col0"]
+ Please refer to the previous Filter Operator [FIL_322]
+ <-Reducer 4 [CUSTOM_SIMPLE_EDGE]
+ PARTITION_ONLY_SHUFFLE [RS_82]
+ Merge Join Operator [MERGEJOIN_270] (rows=696954748 width=97)
+ Conds:(Inner),Output:["_col2","_col4","_col10"]
+ <-Reducer 3 [CUSTOM_SIMPLE_EDGE]
+ PARTITION_ONLY_SHUFFLE [RS_79]
+ Merge Join Operator [MERGEJOIN_269] (rows=696954748 width=88)
+ Conds:RS_76._col1=RS_77._col5(Inner),Output:["_col2","_col4","_col10"]
+ <-Reducer 15 [SIMPLE_EDGE]
+ SHUFFLE [RS_77]
+ PartitionCols:_col5
+ Merge Join Operator [MERGEJOIN_268] (rows=316240138 width=135)
+ Conds:RS_46._col0=RS_321._col1(Inner),Output:["_col5"]
+ <-Reducer 14 [SIMPLE_EDGE]
+ SHUFFLE [RS_46]
+ PartitionCols:_col0
+ Merge Join Operator [MERGEJOIN_264] (rows=44000000 width=1014)
+ Conds:RS_297._col1, _col2=RS_300._col0, _col1(Inner),Output:["_col0"]
+ <-Map 13 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_297]
+ PartitionCols:_col1, _col2
+ Select Operator [SEL_296] (rows=40000000 width=1014)
+ Output:["_col0","_col1","_col2"]
+ Filter Operator [FIL_295] (rows=40000000 width=1014)
+ predicate:(ca_address_sk is not null and ca_county is not null and ca_state is not null)
+ TableScan [TS_6] (rows=40000000 width=1014)
+ default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_county","ca_state"]
+ <-Map 16 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_300]
+ PartitionCols:_col0, _col1
+ Select Operator [SEL_299] (rows=1704 width=1910)
+ Output:["_col0","_col1"]
+ Filter Operator [FIL_298] (rows=1704 width=1910)
+ predicate:(s_county is not null and s_state is not null)
+ TableScan [TS_9] (rows=1704 width=1910)
+ default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_county","s_state"]
+ <-Reducer 22 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_321]
+ PartitionCols:_col1
+ Select Operator [SEL_320] (rows=287491029 width=135)
Output:["_col0","_col1"]
- Filter Operator [FIL_298] (rows=1704 width=1910)
- predicate:(s_county is not null and s_state is not null)
- TableScan [TS_32] (rows=1704 width=1910)
- default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_county","s_state"]
- <-Reducer 21 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_321]
- PartitionCols:_col1
- Select Operator [SEL_320] (rows=287491029 width=135)
- Output:["_col0","_col1"]
- Group By Operator [GBY_319] (rows=287491029 width=135)
- Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
- <-Reducer 20 [SIMPLE_EDGE]
- SHUFFLE [RS_63]
- PartitionCols:_col0, _col1
- Group By Operator [GBY_62] (rows=574982058 width=135)
- Output:["_col0","_col1"],keys:_col10, _col9
- Merge Join Operator [MERGEJOIN_267] (rows=574982058 width=135)
- Conds:RS_58._col1=RS_315._col0(Inner),Output:["_col9","_col10"]
- <-Map 27 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_315]
- PartitionCols:_col0
- Select Operator [SEL_314] (rows=80000000 width=860)
- Output:["_col0","_col1"]
- Filter Operator [FIL_313] (rows=80000000 width=860)
- predicate:(c_current_addr_sk is not null and c_customer_sk is not null)
- TableScan [TS_49] (rows=80000000 width=860)
- default@customer,customer,Tbl:COMPLETE,Col:NONE,Output:["c_customer_sk","c_current_addr_sk"]
- <-Reducer 19 [SIMPLE_EDGE]
- SHUFFLE [RS_58]
- PartitionCols:_col1
- Merge Join Operator [MERGEJOIN_266] (rows=522710951 width=135)
- Conds:RS_55._col2=RS_309._col0(Inner),Output:["_col1"]
- <-Map 25 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_309]
+ Group By Operator [GBY_319] (rows=287491029 width=135)
+ Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
+ <-Reducer 21 [SIMPLE_EDGE]
+ SHUFFLE [RS_40]
+ PartitionCols:_col0, _col1
+ Group By Operator [GBY_39] (rows=574982058 width=135)
+ Output:["_col0","_col1"],keys:_col10, _col9
+ Merge Join Operator [MERGEJOIN_267] (rows=574982058 width=135)
+ Conds:RS_35._col1=RS_315._col0(Inner),Output:["_col9","_col10"]
+ <-Map 28 [SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_315]
PartitionCols:_col0
- Select Operator [SEL_308] (rows=115500 width=1436)
- Output:["_col0"]
- Filter Operator [FIL_307] (rows=115500 width=1436)
- predicate:((i_category = 'Jewelry') and (i_class = 'consignment') and i_item_sk is not null)
- TableScan [TS_46] (rows=462000 width=1436)
- default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_class","i_category"]
- <-Reducer 18 [SIMPLE_EDGE]
- SHUFFLE [RS_55]
- PartitionCols:_col2
- Merge Join Operator [MERGEJOIN_265] (rows=475191764 width=135)
- Conds:Union 17._col0=RS_303._col0(Inner),Output:["_col1","_col2"]
- <-Map 23 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_303]
+ Select Operator [SEL_314] (rows=80000000 width=860)
+ Output:["_col0","_col1"]
+ Filter Operator [FIL_313] (rows=80000000 width=860)
+ predicate:(c_current_addr_sk is not null and c_customer_sk is not null)
+ TableScan [TS_26] (rows=80000000 width=860)
+ default@customer,customer,Tbl:COMPLETE,Col:NONE,Output:["c_customer_sk","c_current_addr_sk"]
+ <-Reducer 20 [SIMPLE_EDGE]
+ SHUFFLE [RS_35]
+ PartitionCols:_col1
+ Merge Join Operator [MERGEJOIN_266] (rows=522710951 width=135)
+ Conds:RS_32._col2=RS_309._col0(Inner),Output:["_col1"]
+ <-Map 26 [SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_309]
PartitionCols:_col0
- Select Operator [SEL_302] (rows=18262 width=1119)
+ Select Operator [SEL_308] (rows=115500 width=1436)
Output:["_col0"]
- Filter Operator [FIL_301] (rows=18262 width=1119)
- predicate:((d_moy = 3) and (d_year = 1999) and d_date_sk is not null)
- TableScan [TS_43] (rows=73049 width=1119)
- default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
- <-Union 17 [SIMPLE_EDGE]
- <-Map 16 [CONTAINS] vectorized
- Reduce Output Operator [RS_371]
- PartitionCols:_col0
- Select Operator [SEL_370] (rows=287989836 width=135)
- Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_369] (rows=287989836 width=135)
- predicate:((cs_bill_customer_sk BETWEEN DynamicValue(RS_59_customer_c_customer_sk_min) AND DynamicValue(RS_59_customer_c_customer_sk_max) and in_bloom_filter(cs_bill_customer_sk, DynamicValue(RS_59_customer_c_customer_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_56_item_i_item_sk_min) AND DynamicValue(RS_56_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_56_item_i_item_sk_bloom_filter))) and (cs_sold_date_sk BETWEEN DynamicValue(RS_53_date_dim_d_date_sk_min) AND DynamicValue(RS_53_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_53_date_dim_d_date_sk_bloom_filter))) and cs_bill_customer_sk is not null and cs_item_sk is not null and cs_sold_date_sk is not null)
- TableScan [TS_274] (rows=287989836 width=135)
- Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_item_sk"]
- <-Reducer 24 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_362]
- Group By Operator [GBY_361] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 23 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_306]
- Group By Operator [GBY_305] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_304] (rows=18262 width=1119)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_302]
- <-Reducer 26 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_365]
- Group By Operator [GBY_364] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 25 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_312]
- Group By Operator [GBY_311] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_310] (rows=115500 width=1436)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_308]
- <-Reducer 28 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_368]
- Group By Operator [GBY_367] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=80000000)"]
- <-Map 27 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_318]
- Group By Operator [GBY_317] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=80000000)"]
- Select Operator [SEL_316] (rows=80000000 width=860)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_314]
- <-Map 22 [CONTAINS] vectorized
- Reduce Output Operator [RS_374]
- PartitionCols:_col0
- Select Operator [SEL_373] (rows=144002668 width=135)
- Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_372] (rows=144002668 width=135)
- predicate:((ws_item_sk BETWEEN DynamicValue(RS_56_item_i_item_sk_min) AND DynamicValue(RS_56_item_i_item_sk_max) and in_bloom_filter(ws_item_sk, DynamicValue(RS_56_item_i_item_sk_bloom_filter))) and (ws_sold_date_sk BETWEEN DynamicValue(RS_53_date_dim_d_date_sk_min) AND DynamicValue(RS_53_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_53_date_dim_d_date_sk_bloom_filter))) and ws_bill_customer_sk is not null and ws_item_sk is not null and ws_sold_date_sk is not null)
- TableScan [TS_279] (rows=144002668 width=135)
- Output:["ws_sold_date_sk","ws_item_sk","ws_bill_customer_sk"]
- <-Reducer 24 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_363]
- Please refer to the previous Group By Operator [GBY_361]
- <-Reducer 26 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_366]
- Please refer to the previous Group By Operator [GBY_364]
- <-Reducer 2 [SIMPLE_EDGE]
- SHUFFLE [RS_99]
- PartitionCols:_col1
- Merge Join Operator [MERGEJOIN_263] (rows=633595212 width=88)
- Conds:RS_294._col0=RS_286._col0(Inner),Output:["_col1","_col2","_col4"]
- <-Map 10 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_286]
- PartitionCols:_col0
- Select Operator [SEL_285] (rows=73049 width=1119)
- Output:["_col0","_col1"]
- Filter Operator [FIL_284] (rows=73049 width=1119)
- predicate:d_date_sk is not null
- TableScan [TS_26] (rows=73049 width=1119)
- default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
- <-Map 1 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_294]
- PartitionCols:_col0
- Select Operator [SEL_293] (rows=575995635 width=88)
- Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_292] (rows=575995635 width=88)
- predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_97_date_dim_d_date_sk_min) AND DynamicValue(RS_97_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_97_date_dim_d_date_sk_bloom_filter))) and ss_customer_sk is not null and ss_sold_date_sk is not null)
- TableScan [TS_23] (rows=575995635 width=88)
- default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_customer_sk","ss_ext_sales_price"]
- <-Reducer 11 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_291]
- Group By Operator [GBY_290] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 10 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_289]
- Group By Operator [GBY_288] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_287] (rows=73049 width=1119)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_285]
- <-Reducer 31 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_340]
- Select Operator [SEL_339] (rows=1 width=8)
- Filter Operator [FIL_338] (rows=1 width=8)
- predicate:(sq_count_check(_col0) <= 1)
- Group By Operator [GBY_337] (rows=1 width=8)
- Output:["_col0"],aggregations:["count(VALUE._col0)"]
- <-Reducer 30 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_336]
- Group By Operator [GBY_335] (rows=1 width=8)
- Output:["_col0"],aggregations:["count()"]
- Select Operator [SEL_333] (rows=9131 width=1119)
- Please refer to the previous Group By Operator [GBY_332]
+ Filter Operator [FIL_307] (rows=115500 width=1436)
+ predicate:((i_category = 'Jewelry') and (i_class = 'consignment') and i_item_sk is not null)
+ TableScan [TS_23] (rows=462000 width=1436)
+ default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_class","i_category"]
+ <-Reducer 19 [SIMPLE_EDGE]
+ SHUFFLE [RS_32]
+ PartitionCols:_col2
+ Merge Join Operator [MERGEJOIN_265] (rows=475191764 width=135)
+ Conds:Union 18._col0=RS_303._col0(Inner),Output:["_col1","_col2"]
+ <-Map 24 [SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_303]
+ PartitionCols:_col0
+ Select Operator [SEL_302] (rows=18262 width=1119)
+ Output:["_col0"]
+ Filter Operator [FIL_301] (rows=18262 width=1119)
+ predicate:((d_moy = 3) and (d_year = 1999) and d_date_sk is not null)
+ TableScan [TS_20] (rows=73049 width=1119)
+ default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
+ <-Union 18 [SIMPLE_EDGE]
+ <-Map 17 [CONTAINS] vectorized
+ Reduce Output Operator [RS_371]
+ PartitionCols:_col0
+ Select Operator [SEL_370] (rows=287989836 width=135)
+ Output:["_col0","_col1","_col2"]
+ Filter Operator [FIL_369] (rows=287989836 width=135)
+ predicate:((cs_bill_customer_sk BETWEEN DynamicValue(RS_36_customer_c_customer_sk_min) AND DynamicValue(RS_36_customer_c_customer_sk_max) and in_bloom_filter(cs_bill_customer_sk, DynamicValue(RS_36_customer_c_customer_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_33_item_i_item_sk_min) AND DynamicValue(RS_33_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_33_item_i_item_sk_bloom_filter))) and (cs_sold_date_sk BETWEEN DynamicValue(RS_30_date_dim_d_date_sk_min) AND DynamicValue(RS_30_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_30_date_dim_d_date_sk_bloom_filter))) and cs_bill_customer_sk is not null and cs_item_sk is not null and cs_sold_date_sk is not null)
+ TableScan [TS_274] (rows=287989836 width=135)
+ Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_item_sk"]
+ <-Reducer 25 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_362]
+ Group By Operator [GBY_361] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 24 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_306]
+ Group By Operator [GBY_305] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_304] (rows=18262 width=1119)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_302]
+ <-Reducer 27 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_365]
+ Group By Operator [GBY_364] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 26 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_312]
+ Group By Operator [GBY_311] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_310] (rows=115500 width=1436)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_308]
+ <-Reducer 29 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_368]
+ Group By Operator [GBY_367] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=80000000)"]
+ <-Map 28 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_318]
+ Group By Operator [GBY_317] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=80000000)"]
+ Select Operator [SEL_316] (rows=80000000 width=860)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_314]
+ <-Map 23 [CONTAINS] vectorized
+ Reduce Output Operator [RS_374]
+ PartitionCols:_col0
+ Select Operator [SEL_373] (rows=144002668 width=135)
+ Output:["_col0","_col1","_col2"]
+ Filter Operator [FIL_372] (rows=144002668 width=135)
+ predicate:((ws_item_sk BETWEEN DynamicValue(RS_33_item_i_item_sk_min) AND DynamicValue(RS_33_item_i_item_sk_max) and in_bloom_filter(ws_item_sk, DynamicValue(RS_33_item_i_item_sk_bloom_filter))) and (ws_sold_date_sk BETWEEN DynamicValue(RS_30_date_dim_d_date_sk_min) AND DynamicValue(RS_30_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_30_date_dim_d_date_sk_bloom_filter))) and ws_bill_customer_sk is not null and ws_item_sk is not null and ws_sold_date_sk is not null)
+ TableScan [TS_279] (rows=144002668 width=135)
+ Output:["ws_sold_date_sk","ws_item_sk","ws_bill_customer_sk"]
+ <-Reducer 25 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_363]
+ Please refer to the previous Group By Operator [GBY_361]
+ <-Reducer 27 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_366]
+ Please refer to the previous Group By Operator [GBY_364]
+ <-Reducer 2 [SIMPLE_EDGE]
+ SHUFFLE [RS_76]
+ PartitionCols:_col1
+ Merge Join Operator [MERGEJOIN_263] (rows=633595212 width=88)
+ Conds:RS_294._col0=RS_286._col0(Inner),Output:["_col1","_col2","_col4"]
+ <-Map 11 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_286]
+ PartitionCols:_col0
+ Select Operator [SEL_285] (rows=73049 width=1119)
+ Output:["_col0","_col1"]
+ Filter Operator [FIL_284] (rows=73049 width=1119)
+ predicate:d_date_sk is not null
+ TableScan [TS_3] (rows=73049 width=1119)
+ default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
+ <-Map 1 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_294]
+ PartitionCols:_col0
+ Select Operator [SEL_293] (rows=575995635 width=88)
+ Output:["_col0","_col1","_col2"]
+ Filter Operator [FIL_292] (rows=575995635 width=88)
+ predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_74_date_dim_d_date_sk_min) AND DynamicValue(RS_74_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_74_date_dim_d_date_sk_bloom_filter))) and ss_customer_sk is not null 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_customer_sk","ss_ext_sales_price"]
+ <-Reducer 12 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_291]
+ Group By Operator [GBY_290] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 11 [CUSTOM_SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_289]
+ Group By Operator [GBY_288] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_287] (rows=73049 width=1119)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_285]
+ <-Reducer 32 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_340]
+ Select Operator [SEL_339] (rows=1 width=8)
+ Filter Operator [FIL_338] (rows=1 width=8)
+ predicate:(sq_count_check(_col0) <= 1)
+ Group By Operator [GBY_337] (rows=1 width=8)
+ Output:["_col0"],aggregations:["count(VALUE._col0)"]
+ <-Reducer 31 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_336]
+ Group By Operator [GBY_335] (rows=1 width=8)
+ Output:["_col0"],aggregations:["count()"]
+ Select Operator [SEL_333] (rows=9131 width=1119)
+ Please refer to the previous Group By Operator [GBY_332]