http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vector_auto_smb_mapjoin_14.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vector_auto_smb_mapjoin_14.q.out b/ql/src/test/results/clientpositive/tez/vector_auto_smb_mapjoin_14.q.out index 51c4ac8..7175be0 100644 --- a/ql/src/test/results/clientpositive/tez/vector_auto_smb_mapjoin_14.q.out +++ b/ql/src/test/results/clientpositive/tez/vector_auto_smb_mapjoin_14.q.out @@ -60,50 +60,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:key is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:key is not null (type: boolean) - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=11 width=93) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=10 width=93) + predicate:key is not null + TableScan [TS_3] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=10 width=93) + predicate:key is not null + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from ( select a.key as key, a.value as val1, b.value as val2 from tbl1 a join tbl2 b on a.key = b.key @@ -149,67 +130,39 @@ Reducer 2 <- Map 1 (SIMPLE_EDGE) Reducer 3 <- Reducer 2 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 3 vectorized - File Output Operator [FS_19] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_29] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 2 [SIMPLE_EDGE] vectorized - Reduce Output Operator [RS_16] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [OP_28] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Select Operator [OP_27] - Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - Group By Operator [OP_26] - | keys:KEY._col0 (type: int) - | outputColumnNames:["_col0"] - | Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - key expressions:_col0 (type: int) - Map-reduce partition columns:_col0 (type: int) - sort order:+ - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Group By Operator [GBY_10] - keys:_col0 (type: int) - outputColumnNames:["_col0"] - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_24] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | outputColumnNames:["_col0"] - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_23] - | predicate:key is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_22] - predicate:key is not null (type: boolean) - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 3 vectorized + File Output Operator [FS_19] + Group By Operator [OP_29] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Reducer 2 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_16] + Group By Operator [OP_28] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Select Operator [OP_27] (rows=5 width=93) + Group By Operator [OP_26] (rows=5 width=93) + Output:["_col0"],keys:KEY._col0 + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + PartitionCols:_col0 + Group By Operator [GBY_10] (rows=11 width=93) + Output:["_col0"],keys:_col0 + Merge Join Operator [MERGEJOIN_24] (rows=11 width=93) + Conds:SEL_2._col0=SEL_5._col0(Inner),Output:["_col0"] + <-Select Operator [SEL_5] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_23] (rows=10 width=93) + predicate:key is not null + TableScan [TS_3] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_22] (rows=10 width=93) + predicate:key is not null + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from ( @@ -282,118 +235,63 @@ Reducer 3 <- Reducer 2 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE) Reducer 6 <- Map 5 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 3 - File Output Operator [FS_32] - compressed:false - Statistics:Num rows: 5 Data size: 511 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Select Operator [SEL_31] - outputColumnNames:["_col0","_col1","_col2"] - Statistics:Num rows: 5 Data size: 511 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_49] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | outputColumnNames:["_col0","_col1","_col3"] - | Statistics:Num rows: 5 Data size: 511 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 2 [SIMPLE_EDGE] vectorized - | Reduce Output Operator [RS_51] - | key expressions:_col0 (type: int) - | Map-reduce partition columns:_col0 (type: int) - | sort order:+ - | Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - | value expressions:_col1 (type: bigint) - | Group By Operator [OP_50] - | | aggregations:["count(VALUE._col0)"] - | | keys:KEY._col0 (type: int) - | | outputColumnNames:["_col0","_col1"] - | | Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - | |<-Map 1 [SIMPLE_EDGE] - | Reduce Output Operator [RS_11] - | key expressions:_col0 (type: int) - | Map-reduce partition columns:_col0 (type: int) - | sort order:+ - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | value expressions:_col1 (type: bigint) - | Group By Operator [GBY_10] - | aggregations:["count()"] - | keys:_col0 (type: int) - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | Merge Join Operator [MERGEJOIN_45] - | | condition map:[{"":"Inner Join 0 to 1"}] - | | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | | outputColumnNames:["_col0"] - | | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | | - | |<-Select Operator [SEL_5] - | | outputColumnNames:["_col0"] - | | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | | Filter Operator [FIL_42] - | | predicate:key is not null (type: boolean) - | | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | | TableScan [TS_3] - | | alias:b - | | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | |<-Select Operator [SEL_2] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_41] - | predicate:key is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_0] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 6 [SIMPLE_EDGE] vectorized - Reduce Output Operator [RS_53] - key expressions:_col0 (type: int) - Map-reduce partition columns:_col0 (type: int) - sort order:+ - Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: bigint) - Group By Operator [OP_52] - | aggregations:["count(VALUE._col0)"] - | keys:KEY._col0 (type: int) - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - |<-Map 5 [SIMPLE_EDGE] - Reduce Output Operator [RS_25] - key expressions:_col0 (type: int) - Map-reduce partition columns:_col0 (type: int) - sort order:+ - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: bigint) - Group By Operator [GBY_24] - aggregations:["count()"] - keys:_col0 (type: int) - outputColumnNames:["_col0","_col1"] - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_47] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | outputColumnNames:["_col0"] - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_19] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_44] - | predicate:key is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_17] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_16] - outputColumnNames:["_col0"] - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_43] - predicate:key is not null (type: boolean) - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_14] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 3 + File Output Operator [FS_32] + Select Operator [SEL_31] (rows=5 width=102) + Output:["_col0","_col1","_col2"] + Merge Join Operator [MERGEJOIN_49] (rows=5 width=102) + Conds:RS_51._col0=RS_53._col0(Inner),Output:["_col0","_col1","_col3"] + <-Reducer 2 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_51] + PartitionCols:_col0 + Group By Operator [OP_50] (rows=5 width=93) + Output:["_col0","_col1"],aggregations:["count(VALUE._col0)"],keys:KEY._col0 + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + PartitionCols:_col0 + Group By Operator [GBY_10] (rows=11 width=93) + Output:["_col0","_col1"],aggregations:["count()"],keys:_col0 + Merge Join Operator [MERGEJOIN_45] (rows=11 width=93) + Conds:SEL_2._col0=SEL_5._col0(Inner),Output:["_col0"] + <-Select Operator [SEL_5] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_42] (rows=10 width=93) + predicate:key is not null + TableScan [TS_3] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_41] (rows=10 width=93) + predicate:key is not null + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Reducer 6 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_53] + PartitionCols:_col0 + Group By Operator [OP_52] (rows=5 width=93) + Output:["_col0","_col1"],aggregations:["count(VALUE._col0)"],keys:KEY._col0 + <-Map 5 [SIMPLE_EDGE] + SHUFFLE [RS_25] + PartitionCols:_col0 + Group By Operator [GBY_24] (rows=11 width=93) + Output:["_col0","_col1"],aggregations:["count()"],keys:_col0 + Merge Join Operator [MERGEJOIN_47] (rows=11 width=93) + Conds:SEL_16._col0=SEL_19._col0(Inner),Output:["_col0"] + <-Select Operator [SEL_19] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_44] (rows=10 width=93) + predicate:key is not null + TableScan [TS_17] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_16] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_43] (rows=10 width=93) + predicate:key is not null + TableScan [TS_14] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select src1.key, src1.cnt1, src2.cnt1 from ( @@ -463,50 +361,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 3 Data size: 306 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:(key < 6) (type: boolean) - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:(key < 6) (type: boolean) - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=3 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_3] (rows=10 width=93) + default@tbl2,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from (select a.key as key, a.value as value from tbl1 a where key < 6) subq1 @@ -561,50 +440,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 1 Data size: 102 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:((key < 8) and (key < 6)) (type: boolean) - | Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:((key < 8) and (key < 6)) (type: boolean) - Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=1 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=1 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=1 width=93) + predicate:((key < 8) and (key < 6)) + TableScan [TS_3] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=1 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=1 width=93) + predicate:((key < 8) and (key < 6)) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from ( @@ -683,50 +543,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 1 Data size: 102 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:((key < 8) and (key < 6)) (type: boolean) - | Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:((key < 8) and (key < 6)) (type: boolean) - Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=1 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=1 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=1 width=93) + predicate:((key < 8) and (key < 6)) + TableScan [TS_3] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=1 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=1 width=93) + predicate:((key < 8) and (key < 6)) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from ( @@ -795,50 +636,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 3 Data size: 306 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:(key < 8) (type: boolean) - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:(key < 8) (type: boolean) - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=3 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=3 width=93) + predicate:(key < 8) + TableScan [TS_3] (rows=10 width=93) + default@tbl2,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=3 width=93) + predicate:(key < 8) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from (select a.key as key, concat(a.value, a.value) as value from tbl1 a where key < 8) subq1 @@ -884,61 +706,37 @@ Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 4 (SIMPLE_EDGE) Reducer 3 <- Reducer 2 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 3 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_28] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 2 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_21] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] vectorized - | Reduce Output Operator [RS_24] - | key expressions:_col0 (type: int) - | Map-reduce partition columns:_col0 (type: int) - | sort order:+ - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | Select Operator [OP_23] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_22] - | predicate:(key + 1) is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_0] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Map 4 [SIMPLE_EDGE] vectorized - Reduce Output Operator [RS_27] - key expressions:_col0 (type: int) - Map-reduce partition columns:_col0 (type: int) - sort order:+ - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - Select Operator [OP_26] - outputColumnNames:["_col0"] - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_25] - predicate:(key + 1) is not null (type: boolean) - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_3] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 3 vectorized + File Output Operator [FS_14] + Group By Operator [OP_28] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Reducer 2 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_21] (rows=11 width=93) + Conds:RS_24._col0=RS_27._col0(Inner) + <-Map 1 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_24] + PartitionCols:_col0 + Select Operator [OP_23] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_22] (rows=10 width=93) + predicate:(key + 1) is not null + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Map 4 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_27] + PartitionCols:_col0 + Select Operator [OP_26] (rows=10 width=93) + Output:["_col0"] + Filter Operator [FIL_25] (rows=10 width=93) + predicate:(key + 1) is not null + TableScan [TS_3] (rows=10 width=93) + default@tbl2,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from (select a.key +1 as key, concat(a.value, a.value) as value from tbl1 a) subq1 @@ -979,50 +777,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 3 Data size: 306 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:(key < 6) (type: boolean) - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:(key < 6) (type: boolean) - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=3 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_3] (rows=10 width=93) + default@tbl2,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from (select a.key as key, a.value as value from tbl1 a where key < 6) subq1 @@ -1069,60 +848,37 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_18] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_31] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_15] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_14] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_28] - | condition map:[{"":"Inner Join 0 to 1"},{"":"Inner Join 0 to 2"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)","2":"_col0 (type: int)"} - | Statistics:Num rows: 6 Data size: 613 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_26] - | predicate:(key < 6) (type: boolean) - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_8] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_27] - | predicate:(key < 6) (type: boolean) - | Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_6] - | alias:a - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_25] - predicate:(key < 6) (type: boolean) - Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_18] + Group By Operator [OP_31] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_15] + Group By Operator [GBY_14] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_28] (rows=6 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner),SEL_2._col0=SEL_8._col0(Inner) + <-Select Operator [SEL_5] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_26] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_3] (rows=10 width=93) + default@tbl2,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_8] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_27] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_6] (rows=10 width=93) + default@tbl2,a,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=3 width=93) + Output:["_col0"] + Filter Operator [FIL_25] (rows=3 width=93) + predicate:(key < 6) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from (select a.key as key, a.value as value from tbl1 a where key < 6) subq1 @@ -1185,50 +941,31 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 vectorized - File Output Operator [FS_14] - compressed:false - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Group By Operator [OP_21] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_10] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_19] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: int)","1":"_col0 (type: int)"} - | Statistics:Num rows: 1 Data size: 102 Basic stats: COMPLETE Column stats: NONE - | - |<-Select Operator [SEL_5] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_18] - | predicate:((key < 8) and (key < 6)) (type: boolean) - | Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_3] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_2] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_17] - predicate:((key < 8) and (key < 6)) (type: boolean) - Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 vectorized + File Output Operator [FS_14] + Group By Operator [OP_21] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_11] + Group By Operator [GBY_10] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Merge Join Operator [MERGEJOIN_19] (rows=1 width=102) + Conds:SEL_2._col0=SEL_5._col0(Inner) + <-Select Operator [SEL_5] (rows=1 width=93) + Output:["_col0"] + Filter Operator [FIL_18] (rows=1 width=93) + predicate:((key < 8) and (key < 6)) + TableScan [TS_3] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Select Operator [SEL_2] (rows=1 width=93) + Output:["_col0"] + Filter Operator [FIL_17] (rows=1 width=93) + predicate:((key < 8) and (key < 6)) + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key"] PREHOOK: query: select count(*) from ( select subq2.key as key, subq2.value as value1, b.value as value2 from @@ -1298,53 +1035,39 @@ POSTHOOK: type: QUERY Plan not optimized by CBO. Stage-4 - Stats-Aggr Operator - Stage-0 - Move Operator - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest1"} - Stage-3 - Dependency Collection{} - Stage-2 - Map 1 - File Output Operator [FS_9] - compressed:false - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest1"} - Select Operator [SEL_8] - outputColumnNames:["_col0","_col1"] - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Select Operator [SEL_7] - outputColumnNames:["_col0","_col1","_col2"] - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_16] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"key (type: int)","1":"key (type: int)"} - | outputColumnNames:["_col0","_col1","_col6"] - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | - |<-Filter Operator [FIL_15] - | predicate:key is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_1] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Filter Operator [FIL_14] - predicate:key is not null (type: boolean) - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - File Output Operator [FS_11] - compressed:false - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest2"} - Please refer to the previous Select Operator [SEL_7] + Stats-Aggr Operator + Stage-0 + Move Operator + table:{"name:":"default.dest1"} + Stage-3 + Dependency Collection{} + Stage-2 + Map 1 + File Output Operator [FS_9] + table:{"name:":"default.dest1"} + Select Operator [SEL_8] (rows=11 width=93) + Output:["_col0","_col1"] + Select Operator [SEL_7] (rows=11 width=93) + Output:["_col0","_col1","_col2"] + Merge Join Operator [MERGEJOIN_16] (rows=11 width=93) + Conds:FIL_14.key=FIL_15.key(Inner),Output:["_col0","_col1","_col6"] + <-Filter Operator [FIL_15] (rows=10 width=93) + predicate:key is not null + TableScan [TS_1] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key","value"] + <-Filter Operator [FIL_14] (rows=10 width=93) + predicate:key is not null + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key","value"] + File Output Operator [FS_11] + table:{"name:":"default.dest2"} + Please refer to the previous Select Operator [SEL_7] Stage-5 - Stats-Aggr Operator - Stage-1 - Move Operator - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest2"} - Please refer to the previous Stage-3 + Stats-Aggr Operator + Stage-1 + Move Operator + table:{"name:":"default.dest2"} + Please refer to the previous Stage-3 PREHOOK: query: from ( select a.key as key, a.value as val1, b.value as val2 from tbl1 a join tbl2 b on a.key = b.key @@ -1471,70 +1194,46 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE) Stage-4 - Stats-Aggr Operator - Stage-0 - Move Operator - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest1"} - Stage-3 - Dependency Collection{} - Stage-2 - Reducer 2 vectorized - File Output Operator [FS_25] - compressed:false - Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest2"} - Select Operator [OP_24] - outputColumnNames:["_col0","_col1"] - Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - Group By Operator [OP_23] - | aggregations:["count(VALUE._col0)"] - | keys:KEY._col0 (type: int) - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 5 Data size: 465 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - File Output Operator [FS_9] - compressed:false - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest1"} - Merge Join Operator [MERGEJOIN_21] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"key (type: int)","1":"key (type: int)"} - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - | - |<-Filter Operator [FIL_20] - | predicate:key is not null (type: boolean) - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_1] - | alias:b - | Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - |<-Filter Operator [FIL_19] - predicate:key is not null (type: boolean) - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:a - Statistics:Num rows: 10 Data size: 930 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator [RS_12] - key expressions:_col0 (type: int) - Map-reduce partition columns:_col0 (type: int) - sort order:+ - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: bigint) - Group By Operator [GBY_11] - aggregations:["count()"] - keys:_col0 (type: int) - outputColumnNames:["_col0","_col1"] - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Select Operator [SEL_10] - outputColumnNames:["_col0"] - Statistics:Num rows: 11 Data size: 1023 Basic stats: COMPLETE Column stats: NONE - Please refer to the previous Merge Join Operator [MERGEJOIN_21] + Stats-Aggr Operator + Stage-0 + Move Operator + table:{"name:":"default.dest1"} + Stage-3 + Dependency Collection{} + Stage-2 + Reducer 2 vectorized + File Output Operator [FS_25] + table:{"name:":"default.dest2"} + Select Operator [OP_24] (rows=5 width=93) + Output:["_col0","_col1"] + Group By Operator [OP_23] (rows=5 width=93) + Output:["_col0","_col1"],aggregations:["count(VALUE._col0)"],keys:KEY._col0 + <-Map 1 [SIMPLE_EDGE] + File Output Operator [FS_9] + table:{"name:":"default.dest1"} + Merge Join Operator [MERGEJOIN_21] (rows=11 width=93) + Conds:FIL_19.key=FIL_20.key(Inner),Output:["_col0","_col1"] + <-Filter Operator [FIL_20] (rows=10 width=93) + predicate:key is not null + TableScan [TS_1] (rows=10 width=93) + default@tbl2,b,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Filter Operator [FIL_19] (rows=10 width=93) + predicate:key is not null + TableScan [TS_0] (rows=10 width=93) + default@tbl1,a,Tbl:COMPLETE,Col:NONE,Output:["key","value"] + SHUFFLE [RS_12] + PartitionCols:_col0 + Group By Operator [GBY_11] (rows=11 width=93) + Output:["_col0","_col1"],aggregations:["count()"],keys:_col0 + Select Operator [SEL_10] (rows=11 width=93) + Output:["_col0"] + Please refer to the previous Merge Join Operator [MERGEJOIN_21] Stage-5 - Stats-Aggr Operator - Stage-1 - Move Operator - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","name:":"default.dest2"} - Please refer to the previous Stage-3 + Stats-Aggr Operator + Stage-1 + Move Operator + table:{"name:":"default.dest2"} + Please refer to the previous Stage-3 PREHOOK: query: from ( select a.key as key, a.value as val1, b.value as val2 from tbl1 a join tbl2 b on a.key = b.key
http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vector_bround.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vector_bround.q.out b/ql/src/test/results/clientpositive/tez/vector_bround.q.out index b520006..05fac27 100644 --- a/ql/src/test/results/clientpositive/tez/vector_bround.q.out +++ b/ql/src/test/results/clientpositive/tez/vector_bround.q.out @@ -41,12 +41,12 @@ POSTHOOK: type: QUERY Plan optimized by CBO. Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1"] - TableScan [TS_0] - alias:test_vector_bround + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1"] + TableScan [TS_0] + Output:["v0","v1"] PREHOOK: query: select bround(v0), bround(v1, 1) from test_vector_bround PREHOOK: type: QUERY http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vector_groupby_mapjoin.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vector_groupby_mapjoin.q.out b/ql/src/test/results/clientpositive/tez/vector_groupby_mapjoin.q.out index dedcec8..037c338 100644 --- a/ql/src/test/results/clientpositive/tez/vector_groupby_mapjoin.q.out +++ b/ql/src/test/results/clientpositive/tez/vector_groupby_mapjoin.q.out @@ -22,89 +22,50 @@ Reducer 3 <- Map 1 (BROADCAST_EDGE), Map 2 (SIMPLE_EDGE), Map 5 (BROADCAST_EDGE) Reducer 4 <- Reducer 3 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 4 vectorized - File Output Operator [FS_34] - compressed:false - Statistics:Num rows: 302 Data size: 3208 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Select Operator [OP_33] - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 302 Data size: 3208 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 3 [SIMPLE_EDGE] vectorized - Reduce Output Operator [RS_22] - key expressions:_col0 (type: string) - sort order:+ - Statistics:Num rows: 302 Data size: 3208 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: string) - Select Operator [SEL_21] - outputColumnNames:["_col0","_col1"] - Statistics:Num rows: 302 Data size: 3208 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_20] - predicate:_col3 is null (type: boolean) - Statistics:Num rows: 302 Data size: 3208 Basic stats: COMPLETE Column stats: NONE - Map Join Operator [MAPJOIN_29] - | condition map:[{"":"Left Outer Join0 to 1"}] - | HybridGraceHashJoin:true - | keys:{"Reducer 3":"_col0 (type: string)","Map 5":"_col0 (type: string)"} - | outputColumnNames:["_col0","_col1","_col3"] - | Statistics:Num rows: 605 Data size: 6427 Basic stats: COMPLETE Column stats: NONE - |<-Map 5 [BROADCAST_EDGE] - | Reduce Output Operator [RS_18] - | key expressions:_col0 (type: string) - | Map-reduce partition columns:_col0 (type: string) - | sort order:+ - | Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - | Select Operator [SEL_12] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_11] - | alias:src - | Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - |<-Map Join Operator [MAPJOIN_28] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{} - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [BROADCAST_EDGE] - | Reduce Output Operator [RS_14] - | sort order: - | Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - | value expressions:_col0 (type: string), _col1 (type: string) - | Select Operator [SEL_1] - | outputColumnNames:["_col0","_col1"] - | Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_0] - | alias:src - | Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - |<-Select Operator [SEL_10] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_9] - predicate:(_col0 = 0) (type: boolean) - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Group By Operator [OP_32] - | aggregations:["count(VALUE._col0)"] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - |<-Map 2 [SIMPLE_EDGE] - Reduce Output Operator [RS_6] - sort order: - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: bigint) - Group By Operator [GBY_5] - aggregations:["count()"] - outputColumnNames:["_col0"] - Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Select Operator [SEL_4] - Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_26] - predicate:key is null (type: boolean) - Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_2] - alias:src - Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 4 vectorized + File Output Operator [FS_34] + Select Operator [OP_33] (rows=302 width=10) + Output:["_col0","_col1"] + <-Reducer 3 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_22] + Select Operator [SEL_21] (rows=302 width=10) + Output:["_col0","_col1"] + Filter Operator [FIL_20] (rows=302 width=10) + predicate:_col3 is null + Map Join Operator [MAPJOIN_29] (rows=605 width=10) + Conds:MAPJOIN_28._col0=RS_18._col0(Left Outer),HybridGraceHashJoin:true,Output:["_col0","_col1","_col3"] + <-Map 5 [BROADCAST_EDGE] + BROADCAST [RS_18] + PartitionCols:_col0 + Select Operator [SEL_12] (rows=500 width=10) + Output:["_col0"] + TableScan [TS_11] (rows=500 width=10) + default@src,src,Tbl:COMPLETE,Col:NONE,Output:["key"] + <-Map Join Operator [MAPJOIN_28] (rows=550 width=10) + Conds:(Inner),Output:["_col0","_col1"] + <-Map 1 [BROADCAST_EDGE] + BROADCAST [RS_14] + Select Operator [SEL_1] (rows=500 width=10) + Output:["_col0","_col1"] + TableScan [TS_0] (rows=500 width=10) + default@src,src,Tbl:COMPLETE,Col:NONE,Output:["key","value"] + <-Select Operator [SEL_10] (rows=1 width=8) + Filter Operator [FIL_9] (rows=1 width=8) + predicate:(_col0 = 0) + Group By Operator [OP_32] (rows=1 width=8) + Output:["_col0"],aggregations:["count(VALUE._col0)"] + <-Map 2 [SIMPLE_EDGE] + SHUFFLE [RS_6] + Group By Operator [GBY_5] (rows=1 width=8) + Output:["_col0"],aggregations:["count()"] + Select Operator [SEL_4] (rows=250 width=10) + Filter Operator [FIL_26] (rows=250 width=10) + predicate:key is null + TableScan [TS_2] (rows=500 width=10) + default@src,src,Tbl:COMPLETE,Col:NONE,Output:["key"] Warning: Map Join MAPJOIN[28][bigTable=?] in task 'Reducer 3' is a cross product PREHOOK: query: select * http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vector_join_part_col_char.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vector_join_part_col_char.q.out b/ql/src/test/results/clientpositive/tez/vector_join_part_col_char.q.out index c7ce2b7..7604538 100644 --- a/ql/src/test/results/clientpositive/tez/vector_join_part_col_char.q.out +++ b/ql/src/test/results/clientpositive/tez/vector_join_part_col_char.q.out @@ -107,55 +107,33 @@ Vertex dependency in root stage Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 3 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 2 - File Output Operator [FS_10] - compressed:false - Statistics:Num rows: 2 Data size: 224 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Merge Join Operator [MERGEJOIN_21] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col2 (type: char(50))","1":"_col2 (type: char(50))"} - | outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"] - | Statistics:Num rows: 2 Data size: 224 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] vectorized - | Reduce Output Operator [RS_23] - | key expressions:_col2 (type: char(50)) - | Map-reduce partition columns:_col2 (type: char(50)) - | sort order:+ - | Statistics:Num rows: 2 Data size: 204 Basic stats: COMPLETE Column stats: NONE - | value expressions:_col0 (type: string), _col1 (type: int) - | Select Operator [OP_22] - | outputColumnNames:["_col0","_col1","_col2"] - | Statistics:Num rows: 2 Data size: 204 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_0] - | alias:c1 - | Statistics:Num rows: 2 Data size: 204 Basic stats: COMPLETE Column stats: NONE - | Dynamic Partitioning Event Operator [EVENT_20] - | Statistics:Num rows: 2 Data size: 204 Basic stats: COMPLETE Column stats: NONE - | Group By Operator [OP_25] - | keys:_col0 (type: char(50)) - | outputColumnNames:["_col0"] - | Statistics:Num rows: 2 Data size: 204 Basic stats: COMPLETE Column stats: NONE - | Select Operator [OP_24] - | outputColumnNames:["_col0"] - | Statistics:Num rows: 2 Data size: 204 Basic stats: COMPLETE Column stats: NONE - | Please refer to the previous Select Operator [OP_22] - |<-Map 3 [SIMPLE_EDGE] vectorized - Reduce Output Operator [RS_27] - key expressions:_col2 (type: char(50)) - Map-reduce partition columns:_col2 (type: char(50)) - sort order:+ - Statistics:Num rows: 2 Data size: 203 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: string), _col1 (type: int) - Select Operator [OP_26] - outputColumnNames:["_col0","_col1","_col2"] - Statistics:Num rows: 2 Data size: 203 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_3] - alias:c2 - Statistics:Num rows: 2 Data size: 203 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 2 + File Output Operator [FS_10] + Merge Join Operator [MERGEJOIN_21] (rows=2 width=112) + Conds:RS_23._col2=RS_27._col2(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5"] + <-Map 1 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_23] + PartitionCols:_col2 + Select Operator [OP_22] (rows=2 width=102) + Output:["_col0","_col1","_col2"] + TableScan [TS_0] (rows=2 width=102) + default@char_tbl1,c1,Tbl:COMPLETE,Col:NONE,Output:["name","age"] + Dynamic Partitioning Event Operator [EVENT_20] (rows=2 width=102) + Group By Operator [OP_25] (rows=2 width=102) + Output:["_col0"],keys:_col0 + Select Operator [OP_24] (rows=2 width=102) + Output:["_col0"] + Please refer to the previous Select Operator [OP_22] + <-Map 3 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_27] + PartitionCols:_col2 + Select Operator [OP_26] (rows=2 width=101) + Output:["_col0","_col1","_col2"] + TableScan [TS_3] (rows=2 width=101) + default@char_tbl2,c2,Tbl:COMPLETE,Col:NONE,Output:["name","age"] PREHOOK: query: select c1.name, c1.age, c1.gpa, c2.name, c2.age, c2.gpa from char_tbl1 c1 join char_tbl2 c2 on (c1.gpa = c2.gpa) PREHOOK: type: QUERY
