hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pxi...@apache.org
Subject [05/33] hive git commit: HIVE-12709: further improve user level explain (Pengcheng Xiong, reviewed by Laljo John Pullokkaran)
Date Fri, 29 Jan 2016 19:06:07 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/explainuser_1.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/tez/explainuser_1.q.out b/ql/src/test/results/clientpositive/tez/explainuser_1.q.out
index 4c7e91b..120894d 100644
--- a/ql/src/test/results/clientpositive/tez/explainuser_1.q.out
+++ b/ql/src/test/results/clientpositive/tez/explainuser_1.q.out
@@ -3,12 +3,8 @@ PREHOOK: type: CREATETABLE
 POSTHOOK: query: explain create table src_orc_merge_test_part(key int, value string) partitioned by (ds string, ts string) stored as orc
 POSTHOOK: type: CREATETABLE
 Stage-0
-   Create Table Operator:
-      columns:["key int","value string"]
-      input format:org.apache.hadoop.hive.ql.io.orc.OrcInputFormat
-      name:default.src_orc_merge_test_part
-      output format:org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat
-      partition columns:["ds string","ts string"]
+  Create Table Operator:
+    name:default.src_orc_merge_test_part
 
 PREHOOK: query: create table src_orc_merge_test_part(key int, value string) partitioned by (ds string, ts string) stored as orc
 PREHOOK: type: CREATETABLE
@@ -50,25 +46,20 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Stage-3
-   Stats-Aggr Operator
-      Stage-0
-         Move Operator
-            partition:{"ds":"2012-01-03","ts":"2012-01-03+14:46:31"}
-            table:{"input format:":"org.apache.hadoop.hive.ql.io.orc.OrcInputFormat","output format:":"org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat","serde:":"org.apache.hadoop.hive.ql.io.orc.OrcSerde","name:":"default.src_orc_merge_test_part"}
-            Stage-2
-               Dependency Collection{}
-                  Stage-1
-                     Map 1
-                     File Output Operator [FS_3]
-                        compressed:false
-                        Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                        table:{"input format:":"org.apache.hadoop.hive.ql.io.orc.OrcInputFormat","output format:":"org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat","serde:":"org.apache.hadoop.hive.ql.io.orc.OrcSerde","name:":"default.src_orc_merge_test_part"}
-                        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
+  Stats-Aggr Operator
+    Stage-0
+      Move Operator
+        table:{"name:":"default.src_orc_merge_test_part"}
+        Stage-2
+          Dependency Collection{}
+            Stage-1
+              Map 1
+              File Output Operator [FS_3]
+                table:{"name:":"default.src_orc_merge_test_part"}
+                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"]
 
 PREHOOK: query: insert overwrite table src_orc_merge_test_part partition(ds='2012-01-03', ts='2012-01-03+14:46:31') select * from src
 PREHOOK: type: QUERY
@@ -90,42 +81,30 @@ Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE)
 
 Stage-3
-   Stats-Aggr Operator
-      Stage-0
-         Move Operator
-            partition:{"ds":"2012-01-03","ts":"2012-01-03+14:46:31"}
-            table:{"input format:":"org.apache.hadoop.hive.ql.io.orc.OrcInputFormat","output format:":"org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat","serde:":"org.apache.hadoop.hive.ql.io.orc.OrcSerde","name:":"default.src_orc_merge_test_part"}
-            Stage-2
-               Dependency Collection{}
-                  Stage-1
-                     Reducer 2
-                     File Output Operator [FS_7]
-                        compressed:false
-                        Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
-                        table:{"input format:":"org.apache.hadoop.hive.ql.io.orc.OrcInputFormat","output format:":"org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat","serde:":"org.apache.hadoop.hive.ql.io.orc.OrcSerde","name:":"default.src_orc_merge_test_part"}
-                        Select Operator [SEL_6]
-                           outputColumnNames:["_col0","_col1"]
-                           Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
-                           Limit [LIM_5]
-                              Number of rows:100
-                              Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
-                              Select Operator [SEL_4]
-                              |  outputColumnNames:["_col0","_col1"]
-                              |  Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
-                              |<-Map 1 [SIMPLE_EDGE]
-                                 Reduce Output Operator [RS_3]
-                                    sort order:
-                                    Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
-                                    value expressions:_col0 (type: string), _col1 (type: string)
-                                    Limit [LIM_2]
-                                       Number of rows:100
-                                       Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
-                                       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
+  Stats-Aggr Operator
+    Stage-0
+      Move Operator
+        table:{"name:":"default.src_orc_merge_test_part"}
+        Stage-2
+          Dependency Collection{}
+            Stage-1
+              Reducer 2
+              File Output Operator [FS_7]
+                table:{"name:":"default.src_orc_merge_test_part"}
+                Select Operator [SEL_6] (rows=100 width=10)
+                  Output:["_col0","_col1"]
+                  Limit [LIM_5] (rows=100 width=10)
+                    Number of rows:100
+                    Select Operator [SEL_4] (rows=100 width=10)
+                      Output:["_col0","_col1"]
+                    <-Map 1 [SIMPLE_EDGE]
+                      SHUFFLE [RS_3]
+                        Limit [LIM_2] (rows=100 width=10)
+                          Number of rows:100
+                          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"]
 
 PREHOOK: query: explain select count(1) from src_orc_merge_test_part where ds='2012-01-03' and ts='2012-01-03+14:46:31'
 PREHOOK: type: QUERY
@@ -137,32 +116,20 @@ Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 2
-         File Output Operator [FS_8]
-            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 [GBY_6]
-            |  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_5]
-                  sort order:
-                  Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE
-                  value expressions:_col0 (type: bigint)
-                  Group By Operator [GBY_4]
-                     aggregations:["count(1)"]
-                     outputColumnNames:["_col0"]
-                     Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE
-                     Select Operator [SEL_2]
-                        Statistics:Num rows: 500 Data size: 47000 Basic stats: COMPLETE Column stats: NONE
-                        TableScan [TS_0]
-                           alias:src_orc_merge_test_part
-                           Statistics:Num rows: 500 Data size: 47000 Basic stats: COMPLETE Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 2
+      File Output Operator [FS_8]
+        Group By Operator [GBY_6] (rows=1 width=8)
+          Output:["_col0"],aggregations:["count(VALUE._col0)"]
+        <-Map 1 [SIMPLE_EDGE]
+          SHUFFLE [RS_5]
+            Group By Operator [GBY_4] (rows=1 width=8)
+              Output:["_col0"],aggregations:["count(1)"]
+              Select Operator [SEL_2] (rows=500 width=94)
+                TableScan [TS_0] (rows=500 width=94)
+                  default@src_orc_merge_test_part,src_orc_merge_test_part,Tbl:COMPLETE,Col:NONE
 
 PREHOOK: query: explain select sum(hash(key)), sum(hash(value)) from src_orc_merge_test_part where ds='2012-01-03' and ts='2012-01-03+14:46:31'
 PREHOOK: type: QUERY
@@ -174,33 +141,21 @@ Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 2
-         File Output Operator [FS_8]
-            compressed:false
-            Statistics:Num rows: 1 Data size: 16 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 [GBY_6]
-            |  aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"]
-            |  outputColumnNames:["_col0","_col1"]
-            |  Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: NONE
-            |<-Map 1 [SIMPLE_EDGE]
-               Reduce Output Operator [RS_5]
-                  sort order:
-                  Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: NONE
-                  value expressions:_col0 (type: bigint), _col1 (type: bigint)
-                  Group By Operator [GBY_4]
-                     aggregations:["sum(_col0)","sum(_col1)"]
-                     outputColumnNames:["_col0","_col1"]
-                     Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: NONE
-                     Select Operator [SEL_2]
-                        outputColumnNames:["_col0","_col1"]
-                        Statistics:Num rows: 500 Data size: 47000 Basic stats: COMPLETE Column stats: NONE
-                        TableScan [TS_0]
-                           alias:src_orc_merge_test_part
-                           Statistics:Num rows: 500 Data size: 47000 Basic stats: COMPLETE Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 2
+      File Output Operator [FS_8]
+        Group By Operator [GBY_6] (rows=1 width=16)
+          Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"]
+        <-Map 1 [SIMPLE_EDGE]
+          SHUFFLE [RS_5]
+            Group By Operator [GBY_4] (rows=1 width=16)
+              Output:["_col0","_col1"],aggregations:["sum(_col0)","sum(_col1)"]
+              Select Operator [SEL_2] (rows=500 width=94)
+                Output:["_col0","_col1"]
+                TableScan [TS_0] (rows=500 width=94)
+                  default@src_orc_merge_test_part,src_orc_merge_test_part,Tbl:COMPLETE,Col:NONE,Output:["key","value"]
 
 PREHOOK: query: alter table src_orc_merge_test_part partition (ds='2012-01-03', ts='2012-01-03+14:46:31') concatenate
 PREHOOK: type: ALTER_PARTITION_MERGE
@@ -220,32 +175,20 @@ Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 2
-         File Output Operator [FS_8]
-            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 [GBY_6]
-            |  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_5]
-                  sort order:
-                  Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE
-                  value expressions:_col0 (type: bigint)
-                  Group By Operator [GBY_4]
-                     aggregations:["count(1)"]
-                     outputColumnNames:["_col0"]
-                     Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE
-                     Select Operator [SEL_2]
-                        Statistics:Num rows: 1 Data size: 2515 Basic stats: PARTIAL Column stats: NONE
-                        TableScan [TS_0]
-                           alias:src_orc_merge_test_part
-                           Statistics:Num rows: 1 Data size: 2515 Basic stats: PARTIAL Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 2
+      File Output Operator [FS_8]
+        Group By Operator [GBY_6] (rows=1 width=8)
+          Output:["_col0"],aggregations:["count(VALUE._col0)"]
+        <-Map 1 [SIMPLE_EDGE]
+          SHUFFLE [RS_5]
+            Group By Operator [GBY_4] (rows=1 width=8)
+              Output:["_col0"],aggregations:["count(1)"]
+              Select Operator [SEL_2] (rows=1 width=2515)
+                TableScan [TS_0] (rows=1 width=2515)
+                  default@src_orc_merge_test_part,src_orc_merge_test_part,Tbl:PARTIAL,Col:NONE
 
 PREHOOK: query: explain select sum(hash(key)), sum(hash(value)) from src_orc_merge_test_part where ds='2012-01-03' and ts='2012-01-03+14:46:31'
 PREHOOK: type: QUERY
@@ -257,33 +200,21 @@ Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 2
-         File Output Operator [FS_8]
-            compressed:false
-            Statistics:Num rows: 1 Data size: 16 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 [GBY_6]
-            |  aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"]
-            |  outputColumnNames:["_col0","_col1"]
-            |  Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: NONE
-            |<-Map 1 [SIMPLE_EDGE]
-               Reduce Output Operator [RS_5]
-                  sort order:
-                  Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: NONE
-                  value expressions:_col0 (type: bigint), _col1 (type: bigint)
-                  Group By Operator [GBY_4]
-                     aggregations:["sum(_col0)","sum(_col1)"]
-                     outputColumnNames:["_col0","_col1"]
-                     Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: NONE
-                     Select Operator [SEL_2]
-                        outputColumnNames:["_col0","_col1"]
-                        Statistics:Num rows: 24 Data size: 2515 Basic stats: COMPLETE Column stats: NONE
-                        TableScan [TS_0]
-                           alias:src_orc_merge_test_part
-                           Statistics:Num rows: 24 Data size: 2515 Basic stats: COMPLETE Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 2
+      File Output Operator [FS_8]
+        Group By Operator [GBY_6] (rows=1 width=16)
+          Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"]
+        <-Map 1 [SIMPLE_EDGE]
+          SHUFFLE [RS_5]
+            Group By Operator [GBY_4] (rows=1 width=16)
+              Output:["_col0","_col1"],aggregations:["sum(_col0)","sum(_col1)"]
+              Select Operator [SEL_2] (rows=24 width=104)
+                Output:["_col0","_col1"]
+                TableScan [TS_0] (rows=24 width=104)
+                  default@src_orc_merge_test_part,src_orc_merge_test_part,Tbl:COMPLETE,Col:NONE,Output:["key","value"]
 
 PREHOOK: query: drop table src_orc_merge_test_part
 PREHOOK: type: DROPTABLE
@@ -322,63 +253,37 @@ Reducer 2 <- Map 1 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 3
-         File Output Operator [FS_17]
-            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 [GBY_15]
-            |  aggregations:["sum(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_14]
-                  sort order:
-                  Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE
-                  value expressions:_col0 (type: bigint)
-                  Group By Operator [GBY_13]
-                     aggregations:["sum(hash(_col0,_col1,_col2,_col3))"]
-                     outputColumnNames:["_col0"]
-                     Statistics:Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE
-                     Select Operator [SEL_11]
-                     |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                     |  Statistics:Num rows: 182 Data size: 1939 Basic stats: COMPLETE Column stats: NONE
-                     |<-Map 1 [SIMPLE_EDGE]
-                        Reduce Output Operator [RS_10]
-                           key expressions:_col0 (type: string), _col1 (type: string), _col2 (type: string), _col3 (type: string)
-                           sort order:++++
-                           Statistics:Num rows: 182 Data size: 1939 Basic stats: COMPLETE Column stats: NONE
-                           Map Join Operator [MAPJOIN_20]
-                           |  condition map:[{"":"Inner Join 0 to 1"}]
-                           |  keys:{}
-                           |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                           |  Statistics:Num rows: 182 Data size: 1939 Basic stats: COMPLETE Column stats: NONE
-                           |<-Map 4 [BROADCAST_EDGE]
-                           |  Reduce Output Operator [RS_7]
-                           |     sort order:
-                           |     Statistics:Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE
-                           |     value expressions:_col0 (type: string), _col1 (type: string)
-                           |     Select Operator [SEL_5]
-                           |        outputColumnNames:["_col0","_col1"]
-                           |        Statistics:Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE
-                           |        Filter Operator [FIL_19]
-                           |           predicate:(key < 10) (type: boolean)
-                           |           Statistics:Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE
-                           |           TableScan [TS_3]
-                           |              alias:src
-                           |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                           |<-Select Operator [SEL_2]
-                                 outputColumnNames:["_col0","_col1"]
-                                 Statistics:Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE
-                                 Filter Operator [FIL_18]
-                                    predicate:(key < 10) (type: boolean)
-                                    Statistics:Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE
-                                    TableScan [TS_0]
-                                       alias:src
-                                       Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 3
+      File Output Operator [FS_17]
+        Group By Operator [GBY_15] (rows=1 width=8)
+          Output:["_col0"],aggregations:["sum(VALUE._col0)"]
+        <-Reducer 2 [SIMPLE_EDGE]
+          SHUFFLE [RS_14]
+            Group By Operator [GBY_13] (rows=1 width=8)
+              Output:["_col0"],aggregations:["sum(hash(_col0,_col1,_col2,_col3))"]
+              Select Operator [SEL_11] (rows=182 width=10)
+                Output:["_col0","_col1","_col2","_col3"]
+              <-Map 1 [SIMPLE_EDGE]
+                SHUFFLE [RS_10]
+                  Map Join Operator [MAPJOIN_20] (rows=182 width=10)
+                    Conds:(Inner),Output:["_col0","_col1","_col2","_col3"]
+                  <-Map 4 [BROADCAST_EDGE]
+                    BROADCAST [RS_7]
+                      Select Operator [SEL_5] (rows=166 width=10)
+                        Output:["_col0","_col1"]
+                        Filter Operator [FIL_19] (rows=166 width=10)
+                          predicate:(key < 10)
+                          TableScan [TS_3] (rows=500 width=10)
+                            default@src,src,Tbl:COMPLETE,Col:NONE,Output:["key","value"]
+                  <-Select Operator [SEL_2] (rows=166 width=10)
+                      Output:["_col0","_col1"]
+                      Filter Operator [FIL_18] (rows=166 width=10)
+                        predicate:(key < 10)
+                        TableScan [TS_0] (rows=500 width=10)
+                          default@src,src,Tbl:COMPLETE,Col:NONE,Output:["key","value"]
 
 PREHOOK: query: explain select key, (c_int+1)+2 as x, sum(c_int) from cbo_t1 group by c_float, cbo_t1.c_int, key
 PREHOOK: type: QUERY
@@ -390,40 +295,24 @@ Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 2
-         File Output Operator [FS_7]
-            compressed:false
-            Statistics:Num rows: 10 Data size: 885 Basic stats: COMPLETE Column stats: COMPLETE
-            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_5]
-               outputColumnNames:["_col0","_col1","_col2"]
-               Statistics:Num rows: 10 Data size: 885 Basic stats: COMPLETE Column stats: COMPLETE
-               Group By Operator [GBY_4]
-               |  aggregations:["sum(VALUE._col0)"]
-               |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-               |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-               |  Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-               |<-Map 1 [SIMPLE_EDGE]
-                  Reduce Output Operator [RS_3]
-                     key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                     Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                     sort order:+++
-                     Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-                     value expressions:_col3 (type: bigint)
-                     Group By Operator [GBY_2]
-                        aggregations:["sum(c_int)"]
-                        keys:key (type: string), c_int (type: int), c_float (type: float)
-                        outputColumnNames:["_col0","_col1","_col2","_col3"]
-                        Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-                        Select Operator [SEL_1]
-                           outputColumnNames:["key","c_int","c_float"]
-                           Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
-                           TableScan [TS_0]
-                              alias:cbo_t1
-                              Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 2
+      File Output Operator [FS_7]
+        Select Operator [SEL_5] (rows=10 width=88)
+          Output:["_col0","_col1","_col2"]
+          Group By Operator [GBY_4] (rows=10 width=91)
+            Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+          <-Map 1 [SIMPLE_EDGE]
+            SHUFFLE [RS_3]
+              PartitionCols:_col0, _col1, _col2
+              Group By Operator [GBY_2] (rows=10 width=91)
+                Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(c_int)"],keys:key, c_int, c_float
+                Select Operator [SEL_1] (rows=20 width=83)
+                  Output:["key","c_int","c_float"]
+                  TableScan [TS_0] (rows=20 width=83)
+                    default@cbo_t1,cbo_t1,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int","c_float"]
 
 PREHOOK: query: explain select x, y, count(*) from (select key, (c_int+c_float+1+2) as x, sum(c_int) as y from cbo_t1 group by c_float, cbo_t1.c_int, key) R group by y, x
 PREHOOK: type: QUERY
@@ -436,60 +325,33 @@ Reducer 2 <- Map 1 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 3
-         File Output Operator [FS_12]
-            compressed:false
-            Statistics:Num rows: 5 Data size: 100 Basic stats: COMPLETE Column stats: COMPLETE
-            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_11]
-               outputColumnNames:["_col0","_col1","_col2"]
-               Statistics:Num rows: 5 Data size: 100 Basic stats: COMPLETE Column stats: COMPLETE
-               Group By Operator [GBY_10]
-               |  aggregations:["count(VALUE._col0)"]
-               |  keys:KEY._col0 (type: bigint), KEY._col1 (type: float)
-               |  outputColumnNames:["_col0","_col1","_col2"]
-               |  Statistics:Num rows: 5 Data size: 100 Basic stats: COMPLETE Column stats: COMPLETE
-               |<-Reducer 2 [SIMPLE_EDGE]
-                  Reduce Output Operator [RS_9]
-                     key expressions:_col0 (type: bigint), _col1 (type: float)
-                     Map-reduce partition columns:_col0 (type: bigint), _col1 (type: float)
-                     sort order:++
-                     Statistics:Num rows: 5 Data size: 100 Basic stats: COMPLETE Column stats: COMPLETE
-                     value expressions:_col2 (type: bigint)
-                     Group By Operator [GBY_8]
-                        aggregations:["count()"]
-                        keys:_col0 (type: bigint), _col1 (type: float)
-                        outputColumnNames:["_col0","_col1","_col2"]
-                        Statistics:Num rows: 5 Data size: 100 Basic stats: COMPLETE Column stats: COMPLETE
-                        Select Operator [SEL_5]
-                           outputColumnNames:["_col0","_col1"]
-                           Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-                           Group By Operator [GBY_4]
-                           |  aggregations:["sum(VALUE._col0)"]
-                           |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                           |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                           |  Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-                           |<-Map 1 [SIMPLE_EDGE]
-                              Reduce Output Operator [RS_3]
-                                 key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                 Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                 sort order:+++
-                                 Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-                                 value expressions:_col3 (type: bigint)
-                                 Group By Operator [GBY_2]
-                                    aggregations:["sum(c_int)"]
-                                    keys:key (type: string), c_int (type: int), c_float (type: float)
-                                    outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                    Statistics:Num rows: 10 Data size: 917 Basic stats: COMPLETE Column stats: COMPLETE
-                                    Select Operator [SEL_1]
-                                       outputColumnNames:["key","c_int","c_float"]
-                                       Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
-                                       TableScan [TS_0]
-                                          alias:cbo_t1
-                                          Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 3
+      File Output Operator [FS_12]
+        Select Operator [SEL_11] (rows=5 width=20)
+          Output:["_col0","_col1","_col2"]
+          Group By Operator [GBY_10] (rows=5 width=20)
+            Output:["_col0","_col1","_col2"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1
+          <-Reducer 2 [SIMPLE_EDGE]
+            SHUFFLE [RS_9]
+              PartitionCols:_col0, _col1
+              Group By Operator [GBY_8] (rows=5 width=20)
+                Output:["_col0","_col1","_col2"],aggregations:["count()"],keys:_col0, _col1
+                Select Operator [SEL_5] (rows=10 width=91)
+                  Output:["_col0","_col1"]
+                  Group By Operator [GBY_4] (rows=10 width=91)
+                    Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                  <-Map 1 [SIMPLE_EDGE]
+                    SHUFFLE [RS_3]
+                      PartitionCols:_col0, _col1, _col2
+                      Group By Operator [GBY_2] (rows=10 width=91)
+                        Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(c_int)"],keys:key, c_int, c_float
+                        Select Operator [SEL_1] (rows=20 width=83)
+                          Output:["key","c_int","c_float"]
+                          TableScan [TS_0] (rows=20 width=83)
+                            default@cbo_t1,cbo_t1,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int","c_float"]
 
 PREHOOK: query: explain select cbo_t3.c_int, c, count(*) from (select key as a, c_int+1 as b, sum(c_int) as c from cbo_t1 where (cbo_t1.c_int + 1 >= 0) and (cbo_t1.c_int > 0 or cbo_t1.c_float >= 0) group by c_float, cbo_t1.c_int, key order by a) cbo_t1 join (select key as p, c_int+1 as q, sum(c_int) as r from cbo_t2 where (cbo_t2.c_int + 1 >= 0) and (cbo_t2.c_int > 0 or cbo_t2.c_float >= 0)  group by c_float, cbo_t2.c_int, key order by q/10 desc, r asc) cbo_t2 on cbo_t1.a=p join cbo_t3 on cbo_t1.a=key where (b + cbo_t2.q >= 0) and (b > 0 or c_int >= 0) group by cbo_t3.c_int, c order by cbo_t3.c_int+c desc, c
 PREHOOK: type: QUERY
@@ -508,172 +370,88 @@ Reducer 7 <- Reducer 6 (SIMPLE_EDGE)
 Reducer 9 <- Map 8 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 7
-         File Output Operator [FS_42]
-            compressed:false
-            Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-            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_41]
-            |  outputColumnNames:["_col0","_col1","_col2"]
-            |  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-            |<-Reducer 6 [SIMPLE_EDGE]
-               Reduce Output Operator [RS_40]
-                  key expressions:(UDFToLong(_col0) + _col1) (type: bigint), _col1 (type: bigint)
-                  sort order:-+
-                  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                  value expressions:_col0 (type: int), _col2 (type: bigint)
-                  Select Operator [SEL_38]
-                     outputColumnNames:["_col0","_col1","_col2"]
-                     Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                     Group By Operator [GBY_37]
-                     |  aggregations:["count(VALUE._col0)"]
-                     |  keys:KEY._col0 (type: bigint), KEY._col1 (type: int)
-                     |  outputColumnNames:["_col0","_col1","_col2"]
-                     |  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                     |<-Reducer 5 [SIMPLE_EDGE]
-                        Reduce Output Operator [RS_36]
-                           key expressions:_col0 (type: bigint), _col1 (type: int)
-                           Map-reduce partition columns:_col0 (type: bigint), _col1 (type: int)
-                           sort order:++
-                           Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                           value expressions:_col2 (type: bigint)
-                           Group By Operator [GBY_35]
-                              aggregations:["count()"]
-                              keys:_col2 (type: bigint), _col6 (type: int)
-                              outputColumnNames:["_col0","_col1","_col2"]
-                              Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                              Select Operator [SEL_34]
-                                 outputColumnNames:["_col2","_col6"]
-                                 Statistics:Num rows: 2 Data size: 32 Basic stats: COMPLETE Column stats: COMPLETE
-                                 Filter Operator [FIL_33]
-                                    predicate:((_col1 > 0) or (_col6 >= 0)) (type: boolean)
-                                    Statistics:Num rows: 2 Data size: 32 Basic stats: COMPLETE Column stats: COMPLETE
-                                    Merge Join Operator [MERGEJOIN_52]
-                                    |  condition map:[{"":"Inner Join 0 to 1"}]
-                                    |  keys:{"0":"_col0 (type: string)","1":"_col0 (type: string)"}
-                                    |  outputColumnNames:["_col1","_col2","_col6"]
-                                    |  Statistics:Num rows: 3 Data size: 48 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |<-Map 11 [SIMPLE_EDGE]
-                                    |  Reduce Output Operator [RS_31]
-                                    |     key expressions:_col0 (type: string)
-                                    |     Map-reduce partition columns:_col0 (type: string)
-                                    |     sort order:+
-                                    |     Statistics:Num rows: 18 Data size: 1424 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |     value expressions:_col1 (type: int)
-                                    |     Select Operator [SEL_29]
-                                    |        outputColumnNames:["_col0","_col1"]
-                                    |        Statistics:Num rows: 18 Data size: 1424 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |        Filter Operator [FIL_50]
-                                    |           predicate:key is not null (type: boolean)
-                                    |           Statistics:Num rows: 18 Data size: 1424 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |           TableScan [TS_27]
-                                    |              alias:cbo_t3
-                                    |              Statistics:Num rows: 20 Data size: 1602 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |<-Reducer 4 [SIMPLE_EDGE]
-                                       Reduce Output Operator [RS_30]
-                                          key expressions:_col0 (type: string)
-                                          Map-reduce partition columns:_col0 (type: string)
-                                          sort order:+
-                                          Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                          value expressions:_col1 (type: int), _col2 (type: bigint)
-                                          Select Operator [SEL_26]
-                                             outputColumnNames:["_col0","_col1","_col2"]
-                                             Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                             Filter Operator [FIL_25]
-                                                predicate:((_col1 + _col4) >= 0) (type: boolean)
-                                                Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                Merge Join Operator [MERGEJOIN_51]
-                                                |  condition map:[{"":"Inner Join 0 to 1"}]
-                                                |  keys:{"0":"_col0 (type: string)","1":"_col0 (type: string)"}
-                                                |  outputColumnNames:["_col0","_col1","_col2","_col4"]
-                                                |  Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |<-Reducer 10 [SIMPLE_EDGE]
-                                                |  Reduce Output Operator [RS_23]
-                                                |     key expressions:_col0 (type: string)
-                                                |     Map-reduce partition columns:_col0 (type: string)
-                                                |     sort order:+
-                                                |     Statistics:Num rows: 1 Data size: 89 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |     value expressions:_col1 (type: int)
-                                                |     Select Operator [SEL_20]
-                                                |     |  outputColumnNames:["_col0","_col1"]
-                                                |     |  Statistics:Num rows: 1 Data size: 89 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |     |<-Reducer 9 [SIMPLE_EDGE]
-                                                |        Reduce Output Operator [RS_19]
-                                                |           key expressions:_col3 (type: double), _col2 (type: bigint)
-                                                |           sort order:-+
-                                                |           Statistics:Num rows: 1 Data size: 105 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |           value expressions:_col0 (type: string), _col1 (type: int)
-                                                |           Select Operator [SEL_17]
-                                                |              outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                |              Statistics:Num rows: 1 Data size: 105 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |              Group By Operator [GBY_16]
-                                                |              |  aggregations:["sum(VALUE._col0)"]
-                                                |              |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                                                |              |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                |              |  Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |              |<-Map 8 [SIMPLE_EDGE]
-                                                |                 Reduce Output Operator [RS_15]
-                                                |                    key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                |                    Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                |                    sort order:+++
-                                                |                    Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |                    value expressions:_col3 (type: bigint)
-                                                |                    Group By Operator [GBY_14]
-                                                |                       aggregations:["sum(c_int)"]
-                                                |                       keys:key (type: string), c_int (type: int), c_float (type: float)
-                                                |                       outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                |                       Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |                       Filter Operator [FIL_49]
-                                                |                          predicate:((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and key is not null) (type: boolean)
-                                                |                          Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |                          TableScan [TS_11]
-                                                |                             alias:cbo_t2
-                                                |                             Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |<-Reducer 3 [SIMPLE_EDGE]
-                                                   Reduce Output Operator [RS_22]
-                                                      key expressions:_col0 (type: string)
-                                                      Map-reduce partition columns:_col0 (type: string)
-                                                      sort order:+
-                                                      Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                                                      value expressions:_col1 (type: int), _col2 (type: bigint)
-                                                      Select Operator [SEL_9]
-                                                      |  outputColumnNames:["_col0","_col1","_col2"]
-                                                      |  Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                                                      |<-Reducer 2 [SIMPLE_EDGE]
-                                                         Reduce Output Operator [RS_8]
-                                                            key expressions:_col0 (type: string)
-                                                            sort order:+
-                                                            Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                                                            value expressions:_col1 (type: int), _col2 (type: bigint)
-                                                            Select Operator [SEL_6]
-                                                               outputColumnNames:["_col0","_col1","_col2"]
-                                                               Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                                                               Group By Operator [GBY_5]
-                                                               |  aggregations:["sum(VALUE._col0)"]
-                                                               |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                                                               |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                               |  Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                               |<-Map 1 [SIMPLE_EDGE]
-                                                                  Reduce Output Operator [RS_4]
-                                                                     key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                                     Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                                     sort order:+++
-                                                                     Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                                     value expressions:_col3 (type: bigint)
-                                                                     Group By Operator [GBY_3]
-                                                                        aggregations:["sum(c_int)"]
-                                                                        keys:key (type: string), c_int (type: int), c_float (type: float)
-                                                                        outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                                        Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                                        Filter Operator [FIL_48]
-                                                                           predicate:((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and key is not null) (type: boolean)
-                                                                           Statistics:Num rows: 3 Data size: 279 Basic stats: COMPLETE Column stats: COMPLETE
-                                                                           TableScan [TS_0]
-                                                                              alias:cbo_t1
-                                                                              Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 7
+      File Output Operator [FS_42]
+        Select Operator [SEL_41] (rows=1 width=20)
+          Output:["_col0","_col1","_col2"]
+        <-Reducer 6 [SIMPLE_EDGE]
+          SHUFFLE [RS_40]
+            Select Operator [SEL_38] (rows=1 width=20)
+              Output:["_col0","_col1","_col2"]
+              Group By Operator [GBY_37] (rows=1 width=20)
+                Output:["_col0","_col1","_col2"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1
+              <-Reducer 5 [SIMPLE_EDGE]
+                SHUFFLE [RS_36]
+                  PartitionCols:_col0, _col1
+                  Group By Operator [GBY_35] (rows=1 width=20)
+                    Output:["_col0","_col1","_col2"],aggregations:["count()"],keys:_col2, _col6
+                    Select Operator [SEL_34] (rows=2 width=16)
+                      Output:["_col2","_col6"]
+                      Filter Operator [FIL_33] (rows=2 width=16)
+                        predicate:((_col1 > 0) or (_col6 >= 0))
+                        Merge Join Operator [MERGEJOIN_52] (rows=3 width=16)
+                          Conds:RS_30._col0=RS_31._col0(Inner),Output:["_col1","_col2","_col6"]
+                        <-Map 11 [SIMPLE_EDGE]
+                          SHUFFLE [RS_31]
+                            PartitionCols:_col0
+                            Select Operator [SEL_29] (rows=18 width=79)
+                              Output:["_col0","_col1"]
+                              Filter Operator [FIL_50] (rows=18 width=79)
+                                predicate:key is not null
+                                TableScan [TS_27] (rows=20 width=80)
+                                  default@cbo_t3,cbo_t3,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int"]
+                        <-Reducer 4 [SIMPLE_EDGE]
+                          SHUFFLE [RS_30]
+                            PartitionCols:_col0
+                            Select Operator [SEL_26] (rows=1 width=101)
+                              Output:["_col0","_col1","_col2"]
+                              Filter Operator [FIL_25] (rows=1 width=101)
+                                predicate:((_col1 + _col4) >= 0)
+                                Merge Join Operator [MERGEJOIN_51] (rows=1 width=101)
+                                  Conds:RS_22._col0=RS_23._col0(Inner),Output:["_col0","_col1","_col2","_col4"]
+                                <-Reducer 10 [SIMPLE_EDGE]
+                                  SHUFFLE [RS_23]
+                                    PartitionCols:_col0
+                                    Select Operator [SEL_20] (rows=1 width=89)
+                                      Output:["_col0","_col1"]
+                                    <-Reducer 9 [SIMPLE_EDGE]
+                                      SHUFFLE [RS_19]
+                                        Select Operator [SEL_17] (rows=1 width=105)
+                                          Output:["_col0","_col1","_col2","_col3"]
+                                          Group By Operator [GBY_16] (rows=1 width=101)
+                                            Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                          <-Map 8 [SIMPLE_EDGE]
+                                            SHUFFLE [RS_15]
+                                              PartitionCols:_col0, _col1, _col2
+                                              Group By Operator [GBY_14] (rows=1 width=101)
+                                                Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(c_int)"],keys:key, c_int, c_float
+                                                Filter Operator [FIL_49] (rows=3 width=93)
+                                                  predicate:((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and key is not null)
+                                                  TableScan [TS_11] (rows=20 width=83)
+                                                    default@cbo_t2,cbo_t2,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int","c_float"]
+                                <-Reducer 3 [SIMPLE_EDGE]
+                                  SHUFFLE [RS_22]
+                                    PartitionCols:_col0
+                                    Select Operator [SEL_9] (rows=1 width=97)
+                                      Output:["_col0","_col1","_col2"]
+                                    <-Reducer 2 [SIMPLE_EDGE]
+                                      SHUFFLE [RS_8]
+                                        Select Operator [SEL_6] (rows=1 width=97)
+                                          Output:["_col0","_col1","_col2"]
+                                          Group By Operator [GBY_5] (rows=1 width=101)
+                                            Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                          <-Map 1 [SIMPLE_EDGE]
+                                            SHUFFLE [RS_4]
+                                              PartitionCols:_col0, _col1, _col2
+                                              Group By Operator [GBY_3] (rows=1 width=101)
+                                                Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(c_int)"],keys:key, c_int, c_float
+                                                Filter Operator [FIL_48] (rows=3 width=93)
+                                                  predicate:((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and key is not null)
+                                                  TableScan [TS_0] (rows=20 width=83)
+                                                    default@cbo_t1,cbo_t1,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int","c_float"]
 
 PREHOOK: query: explain select cbo_t3.c_int, c, count(*) from (select key as a, c_int+1 as b, sum(c_int) as c from cbo_t1 where (cbo_t1.c_int + 1 >= 0) and (cbo_t1.c_int > 0 or cbo_t1.c_float >= 0)  group by c_float, cbo_t1.c_int, key having cbo_t1.c_float > 0 and (c_int >=1 or c_float >= 1) and (c_int + c_float) >= 0 order by b % c asc, b desc) cbo_t1 left outer join (select key as p, c_int+1 as q, sum(c_int) as r from cbo_t2 where (cbo_t2.c_int + 1 >= 0) and (cbo_t2.c_int > 0 or cbo_t2.c_float >= 0)  group by c_float, cbo_t2.c_int, key  having cbo_t2.c_float > 0 and (c_int >=1 or c_float >= 1) and (c_int + c_float) >= 0) cbo_t2 on cbo_t1.a=p left outer join cbo_t3 on cbo_t1.a=key where (b + cbo_t2.q >= 0) and (b > 0 or c_int >= 0) group by cbo_t3.c_int, c  having cbo_t3.c_int > 0 and (c_int >=1 or c >= 1) and (c_int + c) >= 0  order by cbo_t3.c_int % c asc, cbo_t3.c_int desc
 PREHOOK: type: QUERY
@@ -691,160 +469,84 @@ Reducer 7 <- Reducer 6 (SIMPLE_EDGE)
 Reducer 9 <- Map 8 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 7
-         File Output Operator [FS_39]
-            compressed:false
-            Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-            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_38]
-            |  outputColumnNames:["_col0","_col1","_col2"]
-            |  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-            |<-Reducer 6 [SIMPLE_EDGE]
-               Reduce Output Operator [RS_37]
-                  key expressions:(UDFToLong(_col0) % _col1) (type: bigint), _col0 (type: int)
-                  sort order:+-
-                  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                  value expressions:_col1 (type: bigint), _col2 (type: bigint)
-                  Select Operator [SEL_35]
-                     outputColumnNames:["_col0","_col1","_col2"]
-                     Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                     Group By Operator [GBY_34]
-                     |  aggregations:["count(VALUE._col0)"]
-                     |  keys:KEY._col0 (type: bigint), KEY._col1 (type: int)
-                     |  outputColumnNames:["_col0","_col1","_col2"]
-                     |  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                     |<-Reducer 5 [SIMPLE_EDGE]
-                        Reduce Output Operator [RS_33]
-                           key expressions:_col0 (type: bigint), _col1 (type: int)
-                           Map-reduce partition columns:_col0 (type: bigint), _col1 (type: int)
-                           sort order:++
-                           Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                           value expressions:_col2 (type: bigint)
-                           Group By Operator [GBY_32]
-                              aggregations:["count()"]
-                              keys:_col2 (type: bigint), _col6 (type: int)
-                              outputColumnNames:["_col0","_col1","_col2"]
-                              Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                              Select Operator [SEL_31]
-                                 outputColumnNames:["_col2","_col6"]
-                                 Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: COMPLETE
-                                 Filter Operator [FIL_30]
-                                    predicate:(((_col1 > 0) or (_col6 >= 0)) and ((_col6 >= 1) or (_col2 >= 1)) and ((UDFToLong(_col6) + _col2) >= 0)) (type: boolean)
-                                    Statistics:Num rows: 1 Data size: 16 Basic stats: COMPLETE Column stats: COMPLETE
-                                    Merge Join Operator [MERGEJOIN_48]
-                                    |  condition map:[{"":"Inner Join 0 to 1"}]
-                                    |  keys:{"0":"_col0 (type: string)","1":"_col0 (type: string)"}
-                                    |  outputColumnNames:["_col1","_col2","_col6"]
-                                    |  Statistics:Num rows: 2 Data size: 32 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |<-Map 10 [SIMPLE_EDGE]
-                                    |  Reduce Output Operator [RS_28]
-                                    |     key expressions:_col0 (type: string)
-                                    |     Map-reduce partition columns:_col0 (type: string)
-                                    |     sort order:+
-                                    |     Statistics:Num rows: 5 Data size: 356 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |     value expressions:_col1 (type: int)
-                                    |     Select Operator [SEL_26]
-                                    |        outputColumnNames:["_col0","_col1"]
-                                    |        Statistics:Num rows: 5 Data size: 356 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |        Filter Operator [FIL_46]
-                                    |           predicate:((c_int > 0) and key is not null) (type: boolean)
-                                    |           Statistics:Num rows: 5 Data size: 356 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |           TableScan [TS_24]
-                                    |              alias:cbo_t3
-                                    |              Statistics:Num rows: 20 Data size: 1602 Basic stats: COMPLETE Column stats: COMPLETE
-                                    |<-Reducer 4 [SIMPLE_EDGE]
-                                       Reduce Output Operator [RS_27]
-                                          key expressions:_col0 (type: string)
-                                          Map-reduce partition columns:_col0 (type: string)
-                                          sort order:+
-                                          Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                          value expressions:_col1 (type: int), _col2 (type: bigint)
-                                          Select Operator [SEL_23]
-                                             outputColumnNames:["_col0","_col1","_col2"]
-                                             Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                             Filter Operator [FIL_22]
-                                                predicate:((_col1 + _col4) >= 0) (type: boolean)
-                                                Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                Merge Join Operator [MERGEJOIN_47]
-                                                |  condition map:[{"":"Left Outer Join0 to 1"}]
-                                                |  keys:{"0":"_col0 (type: string)","1":"_col0 (type: string)"}
-                                                |  outputColumnNames:["_col0","_col1","_col2","_col4"]
-                                                |  Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |<-Reducer 3 [SIMPLE_EDGE]
-                                                |  Reduce Output Operator [RS_19]
-                                                |     key expressions:_col0 (type: string)
-                                                |     Map-reduce partition columns:_col0 (type: string)
-                                                |     sort order:+
-                                                |     Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |     value expressions:_col1 (type: int), _col2 (type: bigint)
-                                                |     Select Operator [SEL_9]
-                                                |     |  outputColumnNames:["_col0","_col1","_col2"]
-                                                |     |  Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |     |<-Reducer 2 [SIMPLE_EDGE]
-                                                |        Reduce Output Operator [RS_8]
-                                                |           key expressions:_col3 (type: bigint), _col1 (type: int)
-                                                |           sort order:+-
-                                                |           Statistics:Num rows: 1 Data size: 105 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |           value expressions:_col0 (type: string), _col2 (type: bigint)
-                                                |           Select Operator [SEL_6]
-                                                |              outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                |              Statistics:Num rows: 1 Data size: 105 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |              Group By Operator [GBY_5]
-                                                |              |  aggregations:["sum(VALUE._col0)"]
-                                                |              |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                                                |              |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                |              |  Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |              |<-Map 1 [SIMPLE_EDGE]
-                                                |                 Reduce Output Operator [RS_4]
-                                                |                    key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                |                    Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                |                    sort order:+++
-                                                |                    Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |                    value expressions:_col3 (type: bigint)
-                                                |                    Group By Operator [GBY_3]
-                                                |                       aggregations:["sum(c_int)"]
-                                                |                       keys:key (type: string), c_int (type: int), c_float (type: float)
-                                                |                       outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                                |                       Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |                       Filter Operator [FIL_44]
-                                                |                          predicate:(((((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and (c_float > 0.0)) and ((c_int >= 1) or (c_float >= 1.0))) and ((UDFToFloat(c_int) + c_float) >= 0.0)) and key is not null) (type: boolean)
-                                                |                          Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |                          TableScan [TS_0]
-                                                |                             alias:cbo_t1
-                                                |                             Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
-                                                |<-Reducer 9 [SIMPLE_EDGE]
-                                                   Reduce Output Operator [RS_20]
-                                                      key expressions:_col0 (type: string)
-                                                      Map-reduce partition columns:_col0 (type: string)
-                                                      sort order:+
-                                                      Statistics:Num rows: 1 Data size: 89 Basic stats: COMPLETE Column stats: COMPLETE
-                                                      value expressions:_col1 (type: int)
-                                                      Select Operator [SEL_17]
-                                                         outputColumnNames:["_col0","_col1"]
-                                                         Statistics:Num rows: 1 Data size: 89 Basic stats: COMPLETE Column stats: COMPLETE
-                                                         Group By Operator [GBY_16]
-                                                         |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                                                         |  outputColumnNames:["_col0","_col1","_col2"]
-                                                         |  Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                         |<-Map 8 [SIMPLE_EDGE]
-                                                            Reduce Output Operator [RS_15]
-                                                               key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                               Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                                               sort order:+++
-                                                               Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                               Group By Operator [GBY_14]
-                                                                  keys:key (type: string), c_int (type: int), c_float (type: float)
-                                                                  outputColumnNames:["_col0","_col1","_col2"]
-                                                                  Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                                  Filter Operator [FIL_45]
-                                                                     predicate:(((((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and (c_float > 0.0)) and ((c_int >= 1) or (c_float >= 1.0))) and ((UDFToFloat(c_int) + c_float) >= 0.0)) and key is not null) (type: boolean)
-                                                                     Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                                     TableScan [TS_11]
-                                                                        alias:cbo_t2
-                                                                        Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 7
+      File Output Operator [FS_39]
+        Select Operator [SEL_38] (rows=1 width=20)
+          Output:["_col0","_col1","_col2"]
+        <-Reducer 6 [SIMPLE_EDGE]
+          SHUFFLE [RS_37]
+            Select Operator [SEL_35] (rows=1 width=20)
+              Output:["_col0","_col1","_col2"]
+              Group By Operator [GBY_34] (rows=1 width=20)
+                Output:["_col0","_col1","_col2"],aggregations:["count(VALUE._col0)"],keys:KEY._col0, KEY._col1
+              <-Reducer 5 [SIMPLE_EDGE]
+                SHUFFLE [RS_33]
+                  PartitionCols:_col0, _col1
+                  Group By Operator [GBY_32] (rows=1 width=20)
+                    Output:["_col0","_col1","_col2"],aggregations:["count()"],keys:_col2, _col6
+                    Select Operator [SEL_31] (rows=1 width=16)
+                      Output:["_col2","_col6"]
+                      Filter Operator [FIL_30] (rows=1 width=16)
+                        predicate:(((_col1 > 0) or (_col6 >= 0)) and ((_col6 >= 1) or (_col2 >= 1)) and ((UDFToLong(_col6) + _col2) >= 0))
+                        Merge Join Operator [MERGEJOIN_48] (rows=2 width=16)
+                          Conds:RS_27._col0=RS_28._col0(Inner),Output:["_col1","_col2","_col6"]
+                        <-Map 10 [SIMPLE_EDGE]
+                          SHUFFLE [RS_28]
+                            PartitionCols:_col0
+                            Select Operator [SEL_26] (rows=5 width=71)
+                              Output:["_col0","_col1"]
+                              Filter Operator [FIL_46] (rows=5 width=71)
+                                predicate:((c_int > 0) and key is not null)
+                                TableScan [TS_24] (rows=20 width=80)
+                                  default@cbo_t3,cbo_t3,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int"]
+                        <-Reducer 4 [SIMPLE_EDGE]
+                          SHUFFLE [RS_27]
+                            PartitionCols:_col0
+                            Select Operator [SEL_23] (rows=1 width=101)
+                              Output:["_col0","_col1","_col2"]
+                              Filter Operator [FIL_22] (rows=1 width=101)
+                                predicate:((_col1 + _col4) >= 0)
+                                Merge Join Operator [MERGEJOIN_47] (rows=1 width=101)
+                                  Conds:RS_19._col0=RS_20._col0(Left Outer),Output:["_col0","_col1","_col2","_col4"]
+                                <-Reducer 3 [SIMPLE_EDGE]
+                                  SHUFFLE [RS_19]
+                                    PartitionCols:_col0
+                                    Select Operator [SEL_9] (rows=1 width=97)
+                                      Output:["_col0","_col1","_col2"]
+                                    <-Reducer 2 [SIMPLE_EDGE]
+                                      SHUFFLE [RS_8]
+                                        Select Operator [SEL_6] (rows=1 width=105)
+                                          Output:["_col0","_col1","_col2","_col3"]
+                                          Group By Operator [GBY_5] (rows=1 width=101)
+                                            Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2
+                                          <-Map 1 [SIMPLE_EDGE]
+                                            SHUFFLE [RS_4]
+                                              PartitionCols:_col0, _col1, _col2
+                                              Group By Operator [GBY_3] (rows=1 width=101)
+                                                Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(c_int)"],keys:key, c_int, c_float
+                                                Filter Operator [FIL_44] (rows=1 width=93)
+                                                  predicate:(((((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and (c_float > 0.0)) and ((c_int >= 1) or (c_float >= 1.0))) and ((UDFToFloat(c_int) + c_float) >= 0.0)) and key is not null)
+                                                  TableScan [TS_0] (rows=20 width=83)
+                                                    default@cbo_t1,cbo_t1,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int","c_float"]
+                                <-Reducer 9 [SIMPLE_EDGE]
+                                  SHUFFLE [RS_20]
+                                    PartitionCols:_col0
+                                    Select Operator [SEL_17] (rows=1 width=89)
+                                      Output:["_col0","_col1"]
+                                      Group By Operator [GBY_16] (rows=1 width=93)
+                                        Output:["_col0","_col1","_col2"],keys:KEY._col0, KEY._col1, KEY._col2
+                                      <-Map 8 [SIMPLE_EDGE]
+                                        SHUFFLE [RS_15]
+                                          PartitionCols:_col0, _col1, _col2
+                                          Group By Operator [GBY_14] (rows=1 width=93)
+                                            Output:["_col0","_col1","_col2"],keys:key, c_int, c_float
+                                            Filter Operator [FIL_45] (rows=1 width=93)
+                                              predicate:(((((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and (c_float > 0.0)) and ((c_int >= 1) or (c_float >= 1.0))) and ((UDFToFloat(c_int) + c_float) >= 0.0)) and key is not null)
+                                              TableScan [TS_11] (rows=20 width=83)
+                                                default@cbo_t2,cbo_t2,Tbl:COMPLETE,Col:COMPLETE,Output:["key","c_int","c_float"]
 
 PREHOOK: query: explain select cbo_t3.c_int, c, count(*) from (select key as a, c_int+1 as b, sum(c_int) as c from cbo_t1 where (cbo_t1.c_int + 1 >= 0) and (cbo_t1.c_int > 0 or cbo_t1.c_float >= 0)  group by c_float, cbo_t1.c_int, key having cbo_t1.c_float > 0 and (c_int >=1 or c_float >= 1) and (c_int + c_float) >= 0 order by b+c, a desc) cbo_t1 right outer join (select key as p, c_int+1 as q, sum(c_int) as r from cbo_t2 where (cbo_t2.c_int + 1 >= 0) and (cbo_t2.c_int > 0 or cbo_t2.c_float >= 0)  group by c_float, cbo_t2.c_int, key having cbo_t2.c_float > 0 and (c_int >=1 or c_float >= 1) and (c_int + c_float) >= 0) cbo_t2 on cbo_t1.a=p right outer join cbo_t3 on cbo_t1.a=key where (b + cbo_t2.q >= 2) and (b > 0 or c_int >= 0) group by cbo_t3.c_int, c
 PREHOOK: type: QUERY
@@ -860,130 +562,69 @@ Reducer 5 <- Reducer 4 (SIMPLE_EDGE)
 Reducer 7 <- Map 6 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 5
-         File Output Operator [FS_31]
-            compressed:false
-            Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-            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_30]
-               outputColumnNames:["_col0","_col1","_col2"]
-               Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-               Group By Operator [GBY_29]
-               |  aggregations:["count(VALUE._col0)"]
-               |  keys:KEY._col0 (type: bigint), KEY._col1 (type: int)
-               |  outputColumnNames:["_col0","_col1","_col2"]
-               |  Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-               |<-Reducer 4 [SIMPLE_EDGE]
-                  Reduce Output Operator [RS_28]
-                     key expressions:_col0 (type: bigint), _col1 (type: int)
-                     Map-reduce partition columns:_col0 (type: bigint), _col1 (type: int)
-                     sort order:++
-                     Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                     value expressions:_col2 (type: bigint)
-                     Group By Operator [GBY_27]
-                        aggregations:["count()"]
-                        keys:_col2 (type: bigint), _col6 (type: int)
-                        outputColumnNames:["_col0","_col1","_col2"]
-                        Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                        Select Operator [SEL_26]
-                           outputColumnNames:["_col2","_col6"]
-                           Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                           Filter Operator [FIL_25]
-                              predicate:(((_col1 + _col4) >= 2) and ((_col1 > 0) or (_col6 >= 0))) (type: boolean)
-                              Statistics:Num rows: 1 Data size: 20 Basic stats: COMPLETE Column stats: COMPLETE
-                              Merge Join Operator [MERGEJOIN_36]
-                              |  condition map:[{"":"Right Outer Join0 to 1"},{"":"Right Outer Join0 to 2"}]
-                              |  keys:{"0":"_col0 (type: string)","1":"_col0 (type: string)","2":"_col0 (type: string)"}
-                              |  outputColumnNames:["_col1","_col2","_col4","_col6"]
-                              |  Statistics:Num rows: 4 Data size: 80 Basic stats: COMPLETE Column stats: COMPLETE
-                              |<-Map 8 [SIMPLE_EDGE]
-                              |  Reduce Output Operator [RS_23]
-                              |     key expressions:_col0 (type: string)
-                              |     Map-reduce partition columns:_col0 (type: string)
-                              |     sort order:+
-                              |     Statistics:Num rows: 20 Data size: 1602 Basic stats: COMPLETE Column stats: COMPLETE
-                              |     value expressions:_col1 (type: int)
-                              |     Select Operator [SEL_20]
-                              |        outputColumnNames:["_col0","_col1"]
-                              |        Statistics:Num rows: 20 Data size: 1602 Basic stats: COMPLETE Column stats: COMPLETE
-                              |        TableScan [TS_19]
-                              |           alias:cbo_t3
-                              |           Statistics:Num rows: 20 Data size: 1602 Basic stats: COMPLETE Column stats: COMPLETE
-                              |<-Reducer 3 [SIMPLE_EDGE]
-                              |  Reduce Output Operator [RS_21]
-                              |     key expressions:_col0 (type: string)
-                              |     Map-reduce partition columns:_col0 (type: string)
-                              |     sort order:+
-                              |     Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                              |     value expressions:_col1 (type: int), _col2 (type: bigint)
-                              |     Select Operator [SEL_9]
-                              |     |  outputColumnNames:["_col0","_col1","_col2"]
-                              |     |  Statistics:Num rows: 1 Data size: 97 Basic stats: COMPLETE Column stats: COMPLETE
-                              |     |<-Reducer 2 [SIMPLE_EDGE]
-                              |        Reduce Output Operator [RS_8]
-                              |           key expressions:_col3 (type: bigint), _col0 (type: string)
-                              |           sort order:+-
-                              |           Statistics:Num rows: 1 Data size: 105 Basic stats: COMPLETE Column stats: COMPLETE
-                              |           value expressions:_col1 (type: int), _col2 (type: bigint)
-                              |           Select Operator [SEL_6]
-                              |              outputColumnNames:["_col0","_col1","_col2","_col3"]
-                              |              Statistics:Num rows: 1 Data size: 105 Basic stats: COMPLETE Column stats: COMPLETE
-                              |              Group By Operator [GBY_5]
-                              |              |  aggregations:["sum(VALUE._col0)"]
-                              |              |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                              |              |  outputColumnNames:["_col0","_col1","_col2","_col3"]
-                              |              |  Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                              |              |<-Map 1 [SIMPLE_EDGE]
-                              |                 Reduce Output Operator [RS_4]
-                              |                    key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                              |                    Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                              |                    sort order:+++
-                              |                    Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                              |                    value expressions:_col3 (type: bigint)
-                              |                    Group By Operator [GBY_3]
-                              |                       aggregations:["sum(c_int)"]
-                              |                       keys:key (type: string), c_int (type: int), c_float (type: float)
-                              |                       outputColumnNames:["_col0","_col1","_col2","_col3"]
-                              |                       Statistics:Num rows: 1 Data size: 101 Basic stats: COMPLETE Column stats: COMPLETE
-                              |                       Filter Operator [FIL_34]
-                              |                          predicate:((((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and (c_float > 0.0)) and ((c_int >= 1) or (c_float >= 1.0))) and ((UDFToFloat(c_int) + c_float) >= 0.0)) (type: boolean)
-                              |                          Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                              |                          TableScan [TS_0]
-                              |                             alias:cbo_t1
-                              |                             Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
-                              |<-Reducer 7 [SIMPLE_EDGE]
-                                 Reduce Output Operator [RS_22]
-                                    key expressions:_col0 (type: string)
-                                    Map-reduce partition columns:_col0 (type: string)
-                                    sort order:+
-                                    Statistics:Num rows: 1 Data size: 89 Basic stats: COMPLETE Column stats: COMPLETE
-                                    value expressions:_col1 (type: int)
-                                    Select Operator [SEL_17]
-                                       outputColumnNames:["_col0","_col1"]
-                                       Statistics:Num rows: 1 Data size: 89 Basic stats: COMPLETE Column stats: COMPLETE
-                                       Group By Operator [GBY_16]
-                                       |  keys:KEY._col0 (type: string), KEY._col1 (type: int), KEY._col2 (type: float)
-                                       |  outputColumnNames:["_col0","_col1","_col2"]
-                                       |  Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                       |<-Map 6 [SIMPLE_EDGE]
-                                          Reduce Output Operator [RS_15]
-                                             key expressions:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                             Map-reduce partition columns:_col0 (type: string), _col1 (type: int), _col2 (type: float)
-                                             sort order:+++
-                                             Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                             Group By Operator [GBY_14]
-                                                keys:key (type: string), c_int (type: int), c_float (type: float)
-                                                outputColumnNames:["_col0","_col1","_col2"]
-                                                Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                Filter Operator [FIL_35]
-                                                   predicate:((((((c_int + 1) >= 0) and ((c_int > 0) or (c_float >= 0.0))) and (c_float > 0.0)) and ((c_int >= 1) or (c_float >= 1.0))) and ((UDFToFloat(c_int) + c_float) >= 0.0)) (type: boolean)
-                                                   Statistics:Num rows: 1 Data size: 93 Basic stats: COMPLETE Column stats: COMPLETE
-                                                   TableScan [TS_11]
-                                                      alias:cbo_t2
-                                                      Statistics:Num rows: 20 Data size: 1674 Basic stats: COMPLETE Column stats: COMPLETE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 5
+      File Output Operator [FS_31]
+        Select Operator [SEL_30] (rows=1 width=20)
+          Output:["_col0","_col1","_col2"]
+          Group By Operator [GBY_29] (rows=1 width=20)
+            Output:["_col0","_col1","_col2"],aggregations

<TRUNCATED>

Mime
View raw message