Modified: 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_2.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_2.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_2.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_2.q.out 
Mon Feb  2 06:41:02 2015
@@ -274,11 +274,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int)
                     sort order: +
                     Map-reduce partition columns: _col0 (type: int)
-                    value expressions: _col0 (type: int), _col1 (type: string)
+                    value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -340,11 +342,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int)
                     sort order: +
                     Map-reduce partition columns: _col0 (type: int)
-                    value expressions: _col0 (type: int), _col1 (type: string)
+                    value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -376,9 +380,11 @@ STAGE PLANS:
                     key expressions: _col0 (type: int)
                     sort order: +
                     Map-reduce partition columns: _col0 (type: int)
-                    value expressions: _col0 (type: int), _col1 (type: string)
+                    value expressions: _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -989,11 +995,13 @@ STAGE PLANS:
                       key expressions: _col0 (type: int)
                       sort order: +
                       Map-reduce partition columns: _col0 (type: int)
-                      value expressions: _col0 (type: int), _col1 (type: 
string)
+                      value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -1061,11 +1069,13 @@ STAGE PLANS:
                       key expressions: _col0 (type: int)
                       sort order: +
                       Map-reduce partition columns: _col0 (type: int)
-                      value expressions: _col0 (type: int), _col1 (type: 
string)
+                      value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -1101,9 +1111,11 @@ STAGE PLANS:
                       key expressions: _col0 (type: int)
                       sort order: +
                       Map-reduce partition columns: _col0 (type: int)
-                      value expressions: _col0 (type: int), _col1 (type: 
string)
+                      value expressions: _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:

Modified: 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_3.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_3.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_3.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_3.q.out 
Mon Feb  2 06:41:02 2015
@@ -184,20 +184,18 @@ STAGE PLANS:
                 Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
                 value expressions: _col0 (type: int), _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), UDFToInteger(VALUE._col1) 
(type: int)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
-          Select Operator
-            expressions: _col0 (type: int), UDFToInteger(_col1) (type: int)
-            outputColumnNames: _col0, _col1
+          File Output Operator
+            compressed: false
             Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
-            File Output Operator
-              compressed: false
-              Statistics: Num rows: 500 Data size: 5312 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.test_table2
+            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.test_table2
 
   Stage: Stage-0
     Move Operator

Modified: 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_4.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_4.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_4.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_4.q.out 
Mon Feb  2 06:41:02 2015
@@ -71,21 +71,44 @@ FROM test_table1 a JOIN test_table2 b
 ON a.key = b.key WHERE a.ds = '1' and b.ds = '1'
 POSTHOOK: type: QUERY
 STAGE DEPENDENCIES:
-  Stage-1 is a root stage
-  Stage-0 depends on stages: Stage-1
+  Stage-6 is a root stage , consists of Stage-7, Stage-8, Stage-1
+  Stage-7 has a backup stage: Stage-1
+  Stage-4 depends on stages: Stage-7
+  Stage-0 depends on stages: Stage-1, Stage-4, Stage-5
   Stage-2 depends on stages: Stage-0
+  Stage-8 has a backup stage: Stage-1
+  Stage-5 depends on stages: Stage-8
+  Stage-1
 
 STAGE PLANS:
-  Stage: Stage-1
+  Stage: Stage-6
+    Conditional Operator
+
+  Stage: Stage-7
+    Map Reduce Local Work
+      Alias -> Map Local Tables:
+        b 
+          Fetch Operator
+            limit: -1
+      Alias -> Map Local Operator Tree:
+        b 
+          TableScan
+            alias: b
+            Filter Operator
+              predicate: key is not null (type: boolean)
+              HashTable Sink Operator
+                keys:
+                  0 key (type: int)
+                  1 key (type: int)
+
+  Stage: Stage-4
     Map Reduce
       Map Operator Tree:
           TableScan
             alias: a
-            Statistics: Num rows: 10 Data size: 70 Basic stats: COMPLETE 
Column stats: NONE
             Filter Operator
               predicate: key is not null (type: boolean)
-              Statistics: Num rows: 5 Data size: 35 Basic stats: COMPLETE 
Column stats: NONE
-              Sorted Merge Bucket Map Join Operator
+              Map Join Operator
                 condition map:
                      Inner Join 0 to 1
                 keys:
@@ -93,15 +116,26 @@ STAGE PLANS:
                   1 key (type: int)
                 outputColumnNames: _col0, _col1, _col7
                 Select Operator
-                  expressions: _col0 (type: int), _col0 (type: int), 
concat(_col1, _col7) (type: string)
-                  outputColumnNames: _col0, _col1, _col2
-                  File Output Operator
-                    compressed: false
-                    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.test_table3
+                  expressions: _col0 (type: int), concat(_col1, _col7) (type: 
string)
+                  outputColumnNames: _col1, _col2
+                  Reduce Output Operator
+                    key expressions: _col1 (type: int)
+                    sort order: +
+                    Map-reduce partition columns: _col1 (type: int)
+                    value expressions: _col2 (type: string)
+      Local Work:
+        Map Reduce Local Work
+      Reduce Operator Tree:
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey0 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
+          File Output Operator
+            compressed: false
+            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.test_table3
 
   Stage: Stage-0
     Move Operator
@@ -118,6 +152,95 @@ STAGE PLANS:
   Stage: Stage-2
     Stats-Aggr Operator
 
+  Stage: Stage-8
+    Map Reduce Local Work
+      Alias -> Map Local Tables:
+        a 
+          Fetch Operator
+            limit: -1
+      Alias -> Map Local Operator Tree:
+        a 
+          TableScan
+            alias: a
+            Filter Operator
+              predicate: key is not null (type: boolean)
+              HashTable Sink Operator
+                keys:
+                  0 key (type: int)
+                  1 key (type: int)
+
+  Stage: Stage-5
+    Map Reduce
+      Map Operator Tree:
+          TableScan
+            alias: b
+            Filter Operator
+              predicate: key is not null (type: boolean)
+              Map Join Operator
+                condition map:
+                     Inner Join 0 to 1
+                keys:
+                  0 key (type: int)
+                  1 key (type: int)
+                outputColumnNames: _col0, _col1, _col7
+                Select Operator
+                  expressions: _col0 (type: int), concat(_col1, _col7) (type: 
string)
+                  outputColumnNames: _col1, _col2
+                  Reduce Output Operator
+                    key expressions: _col1 (type: int)
+                    sort order: +
+                    Map-reduce partition columns: _col1 (type: int)
+                    value expressions: _col2 (type: string)
+      Local Work:
+        Map Reduce Local Work
+      Reduce Operator Tree:
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey0 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
+          File Output Operator
+            compressed: false
+            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.test_table3
+
+  Stage: Stage-1
+    Map Reduce
+      Map Operator Tree:
+          TableScan
+            alias: a
+            Statistics: Num rows: 10 Data size: 70 Basic stats: COMPLETE 
Column stats: NONE
+            Filter Operator
+              predicate: key is not null (type: boolean)
+              Statistics: Num rows: 5 Data size: 35 Basic stats: COMPLETE 
Column stats: NONE
+              Sorted Merge Bucket Map Join Operator
+                condition map:
+                     Inner Join 0 to 1
+                keys:
+                  0 key (type: int)
+                  1 key (type: int)
+                outputColumnNames: _col0, _col1, _col7
+                Select Operator
+                  expressions: _col0 (type: int), concat(_col1, _col7) (type: 
string)
+                  outputColumnNames: _col1, _col2
+                  Reduce Output Operator
+                    key expressions: _col1 (type: int)
+                    sort order: +
+                    Map-reduce partition columns: _col1 (type: int)
+                    value expressions: _col2 (type: string)
+      Reduce Operator Tree:
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey0 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
+          File Output Operator
+            compressed: false
+            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.test_table3
+
 PREHOOK: query: INSERT OVERWRITE TABLE test_table3 PARTITION (ds = '1')
 SELECT a.key, a.key, concat(a.value, b.value) 
 FROM test_table1 a JOIN test_table2 b 
@@ -266,11 +389,13 @@ STAGE PLANS:
                   key expressions: _col1 (type: string)
                   sort order: +
                   Map-reduce partition columns: _col1 (type: string)
-                  value expressions: _col0 (type: int), _col1 (type: string)
+                  value expressions: _col0 (type: int)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), KEY.reducesinkkey0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -329,11 +454,13 @@ STAGE PLANS:
                   key expressions: _col1 (type: string)
                   sort order: +
                   Map-reduce partition columns: _col1 (type: string)
-                  value expressions: _col0 (type: int), _col1 (type: string)
+                  value expressions: _col0 (type: int)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), KEY.reducesinkkey0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -362,9 +489,11 @@ STAGE PLANS:
                   key expressions: _col1 (type: string)
                   sort order: +
                   Map-reduce partition columns: _col1 (type: string)
-                  value expressions: _col0 (type: int), _col1 (type: string)
+                  value expressions: _col0 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), KEY.reducesinkkey0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:

Modified: 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_5.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_5.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_5.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_5.q.out 
Mon Feb  2 06:41:02 2015
@@ -122,11 +122,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int)
                     sort order: -
                     Map-reduce partition columns: _col0 (type: int)
-                    value expressions: _col0 (type: int), _col1 (type: string)
+                    value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -188,11 +190,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int)
                     sort order: -
                     Map-reduce partition columns: _col0 (type: int)
-                    value expressions: _col0 (type: int), _col1 (type: string)
+                    value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -224,9 +228,11 @@ STAGE PLANS:
                     key expressions: _col0 (type: int)
                     sort order: -
                     Map-reduce partition columns: _col0 (type: int)
-                    value expressions: _col0 (type: int), _col1 (type: string)
+                    value expressions: _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -377,11 +383,13 @@ STAGE PLANS:
                       key expressions: _col0 (type: int)
                       sort order: -
                       Map-reduce partition columns: _col0 (type: int)
-                      value expressions: _col0 (type: int), _col1 (type: 
string)
+                      value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -449,11 +457,13 @@ STAGE PLANS:
                       key expressions: _col0 (type: int)
                       sort order: -
                       Map-reduce partition columns: _col0 (type: int)
-                      value expressions: _col0 (type: int), _col1 (type: 
string)
+                      value expressions: _col1 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:
@@ -489,9 +499,11 @@ STAGE PLANS:
                       key expressions: _col0 (type: int)
                       sort order: -
                       Map-reduce partition columns: _col0 (type: int)
-                      value expressions: _col0 (type: int), _col1 (type: 
string)
+                      value expressions: _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 (type: 
string)
+          outputColumnNames: _col0, _col1
           File Output Operator
             compressed: false
             table:

Modified: 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_6.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_6.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_6.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/bucketsortoptimize_insert_6.q.out 
Mon Feb  2 06:41:02 2015
@@ -394,11 +394,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: +-
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -460,11 +462,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: +-
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -496,9 +500,11 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: +-
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -581,11 +587,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: +-
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -647,11 +655,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: +-
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -683,9 +693,11 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: +-
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -1090,11 +1102,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: --
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -1156,11 +1170,13 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: --
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Local Work:
         Map Reduce Local Work
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:
@@ -1192,9 +1208,11 @@ STAGE PLANS:
                     key expressions: _col0 (type: int), _col1 (type: int)
                     sort order: --
                     Map-reduce partition columns: _col0 (type: int), _col1 
(type: int)
-                    value expressions: _col0 (type: int), _col1 (type: int), 
_col2 (type: string)
+                    value expressions: _col2 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: int), VALUE._col0 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           File Output Operator
             compressed: false
             table:

Modified: 
hive/trunk/ql/src/test/results/clientpositive/disable_merge_for_bucketing.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/disable_merge_for_bucketing.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/disable_merge_for_bucketing.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/disable_merge_for_bucketing.q.out 
Mon Feb  2 06:41:02 2015
@@ -106,39 +106,37 @@ STAGE PLANS:
         /src [src]
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: UDFToInteger(VALUE._col0) (type: int), VALUE._col1 
(type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
-          Select Operator
-            expressions: UDFToInteger(_col0) (type: int), _col1 (type: string)
-            outputColumnNames: _col0, _col1
-            Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
-            File Output Operator
-              compressed: false
-              GlobalTableId: 1
+          File Output Operator
+            compressed: false
+            GlobalTableId: 1
 #### A masked pattern was here ####
-              NumFilesPerFileSink: 2
-              Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
+            NumFilesPerFileSink: 2
+            Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
 #### A masked pattern was here ####
-              table:
-                  input format: org.apache.hadoop.mapred.TextInputFormat
-                  output format: 
org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
-                  properties:
-                    bucket_count 2
-                    bucket_field_name key
-                    columns key,value
-                    columns.comments 
-                    columns.types int:string
+            table:
+                input format: org.apache.hadoop.mapred.TextInputFormat
+                output format: 
org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+                properties:
+                  bucket_count 2
+                  bucket_field_name key
+                  columns key,value
+                  columns.comments 
+                  columns.types int:string
 #### A masked pattern was here ####
-                    name default.bucket2_1
-                    serialization.ddl struct bucket2_1 { i32 key, string value}
-                    serialization.format 1
-                    serialization.lib 
org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+                  name default.bucket2_1
+                  serialization.ddl struct bucket2_1 { i32 key, string value}
+                  serialization.format 1
+                  serialization.lib 
org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
 #### A masked pattern was here ####
-                  serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
-                  name: default.bucket2_1
-              TotalFiles: 2
-              GatherStats: true
-              MultiFileSpray: true
+                serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+                name: default.bucket2_1
+            TotalFiles: 2
+            GatherStats: true
+            MultiFileSpray: true
 
   Stage: Stage-0
     Move Operator

Modified: 
hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_opt_vectorization.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_opt_vectorization.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_opt_vectorization.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_opt_vectorization.q.out
 Mon Feb  2 06:41:02 2015
@@ -206,7 +206,9 @@ STAGE PLANS:
               Statistics: Num rows: 1048 Data size: 310873 Basic stats: 
COMPLETE Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -291,7 +293,9 @@ STAGE PLANS:
               Statistics: Num rows: 10 Data size: 2960 Basic stats: COMPLETE 
Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 10 Data size: 2960 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -349,7 +353,9 @@ STAGE PLANS:
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Execution mode: vectorized
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -406,7 +412,9 @@ STAGE PLANS:
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Execution mode: vectorized
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -555,7 +563,9 @@ STAGE PLANS:
               Statistics: Num rows: 1048 Data size: 310873 Basic stats: 
COMPLETE Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -640,7 +650,9 @@ STAGE PLANS:
               Statistics: Num rows: 10 Data size: 2960 Basic stats: COMPLETE 
Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 10 Data size: 2960 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -698,7 +710,9 @@ STAGE PLANS:
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Execution mode: vectorized
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -755,7 +769,9 @@ STAGE PLANS:
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Execution mode: vectorized
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1381,7 +1397,9 @@ STAGE PLANS:
               Statistics: Num rows: 1048 Data size: 310873 Basic stats: 
COMPLETE Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1468,7 +1486,9 @@ STAGE PLANS:
               Statistics: Num rows: 10 Data size: 2960 Basic stats: COMPLETE 
Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 10 Data size: 2960 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1621,7 +1641,9 @@ STAGE PLANS:
               Statistics: Num rows: 524 Data size: 155436 Basic stats: 
COMPLETE Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 524 Data size: 155436 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -2002,10 +2024,12 @@ STAGE PLANS:
                   sort order: +
                   Map-reduce partition columns: _col0 (type: smallint)
                   Statistics: Num rows: 1048 Data size: 310873 Basic stats: 
COMPLETE Column stats: NONE
-                  value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
+                  value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col4 (type: tinyint)
       Execution mode: vectorized
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), KEY.reducesinkkey0 (type: float), VALUE._col3 
(type: tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -2062,7 +2086,9 @@ STAGE PLANS:
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Execution mode: vectorized
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 1048 Data size: 310873 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_optimization.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_optimization.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_optimization.q.out 
(original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/dynpart_sort_optimization.q.out 
Mon Feb  2 06:41:02 2015
@@ -140,7 +140,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -224,7 +226,9 @@ STAGE PLANS:
               Statistics: Num rows: 10 Data size: 240 Basic stats: COMPLETE 
Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 10 Data size: 240 Basic stats: COMPLETE Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -281,7 +285,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -337,7 +343,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -463,7 +471,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -547,7 +557,9 @@ STAGE PLANS:
               Statistics: Num rows: 10 Data size: 240 Basic stats: COMPLETE 
Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 10 Data size: 240 Basic stats: COMPLETE Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -604,7 +616,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -660,7 +674,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1284,7 +1300,9 @@ STAGE PLANS:
               Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1370,7 +1388,9 @@ STAGE PLANS:
               Statistics: Num rows: 10 Data size: 240 Basic stats: COMPLETE 
Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 10 Data size: 240 Basic stats: COMPLETE Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -1521,7 +1541,9 @@ STAGE PLANS:
               Statistics: Num rows: 2221 Data size: 53305 Basic stats: 
COMPLETE Column stats: NONE
               value expressions: _col0 (type: smallint), _col1 (type: int), 
_col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 2221 Data size: 53305 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1902,9 +1924,11 @@ STAGE PLANS:
                   sort order: +
                   Map-reduce partition columns: _col0 (type: smallint)
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
-                  value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint)
+                  value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col4 (type: tinyint)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), KEY.reducesinkkey0 (type: float), VALUE._col3 
(type: tinyint)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -1960,7 +1984,9 @@ STAGE PLANS:
                   Statistics: Num rows: 4442 Data size: 106611 Basic stats: 
COMPLETE Column stats: NONE
                   value expressions: _col0 (type: smallint), _col1 (type: 
int), _col2 (type: bigint), _col3 (type: float), _col4 (type: tinyint), 
'_bucket_number' (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: smallint), VALUE._col1 (type: int), 
VALUE._col2 (type: bigint), VALUE._col3 (type: float), VALUE._col4 (type: 
tinyint), VALUE._bucket_number (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _bucket_number
           Statistics: Num rows: 4442 Data size: 106611 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out
 Mon Feb  2 06:41:02 2015
@@ -131,7 +131,9 @@ STAGE PLANS:
 #### A masked pattern was here ####
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 0 Data size: 24 Basic stats: PARTIAL Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -403,7 +405,9 @@ STAGE PLANS:
 #### A masked pattern was here ####
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -763,7 +767,9 @@ STAGE PLANS:
         /encryptedTable/key=86 [encryptedtable]
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 21 Data size: 2372 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
 Mon Feb  2 06:41:02 2015
@@ -134,7 +134,9 @@ STAGE PLANS:
 #### A masked pattern was here ####
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 0 Data size: 24 Basic stats: PARTIAL Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -405,7 +407,9 @@ STAGE PLANS:
 #### A masked pattern was here ####
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column 
stats: NONE
           File Output Operator
             compressed: false
@@ -668,7 +672,9 @@ STAGE PLANS:
         /encryptedTable/ds=yesterday [encryptedtable]
       Needs Tagging: false
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 12 Data size: 2695 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: hive/trunk/ql/src/test/results/clientpositive/load_dyn_part2.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/load_dyn_part2.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/load_dyn_part2.q.out 
(original)
+++ hive/trunk/ql/src/test/results/clientpositive/load_dyn_part2.q.out Mon Feb  
2 06:41:02 2015
@@ -60,7 +60,9 @@ STAGE PLANS:
                 Statistics: Num rows: 2000 Data size: 21248 Basic stats: 
COMPLETE Column stats: NONE
                 value expressions: _col0 (type: string), _col1 (type: string), 
_col2 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string), 
VALUE._col2 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 2000 Data size: 21248 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: hive/trunk/ql/src/test/results/clientpositive/ptf.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/ptf.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/ptf.q.out (original)
+++ hive/trunk/ql/src/test/results/clientpositive/ptf.q.out Mon Feb  2 06:41:02 
2015
@@ -41,9 +41,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int), p_retailprice (type: double)
+              value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -211,9 +213,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE 
Column stats: NONE
@@ -333,9 +337,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: string), KEY.reducesinkkey1 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col2, _col1, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -436,9 +442,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int), p_retailprice (type: double)
+              value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -571,9 +579,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -709,9 +719,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -870,9 +882,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_partkey (type: int), p_name (type: string), 
p_mfgr (type: string), p_brand (type: string), p_type (type: string), p_size 
(type: int), p_container (type: string), p_retailprice (type: double), 
p_comment (type: string)
+              value expressions: p_partkey (type: int), p_brand (type: 
string), p_type (type: string), p_size (type: int), p_container (type: string), 
p_retailprice (type: double), p_comment (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), KEY.reducesinkkey1 (type: 
string), KEY.reducesinkkey0 (type: string), VALUE._col1 (type: string), 
VALUE._col2 (type: string), VALUE._col3 (type: int), VALUE._col4 (type: 
string), VALUE._col5 (type: double), VALUE._col6 (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, 
_col7, _col8
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1007,9 +1021,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_partkey (type: int), p_name (type: string), 
p_mfgr (type: string), p_brand (type: string), p_type (type: string), p_size 
(type: int), p_container (type: string), p_retailprice (type: double), 
p_comment (type: string)
+              value expressions: p_partkey (type: int), p_brand (type: 
string), p_type (type: string), p_size (type: int), p_container (type: string), 
p_retailprice (type: double), p_comment (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), KEY.reducesinkkey1 (type: 
string), KEY.reducesinkkey0 (type: string), VALUE._col1 (type: string), 
VALUE._col2 (type: string), VALUE._col3 (type: int), VALUE._col4 (type: 
string), VALUE._col5 (type: double), VALUE._col6 (type: string)
+          outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, 
_col7, _col8
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1150,9 +1166,10 @@ STAGE PLANS:
                 sort order: ++-
                 Map-reduce partition columns: p_mfgr (type: string)
                 Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-                value expressions: p_name (type: string), p_mfgr (type: 
string), p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), KEY.reducesinkkey2 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1278,9 +1295,11 @@ STAGE PLANS:
                 sort order: ++
                 Map-reduce partition columns: p_mfgr (type: string)
                 Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-                value expressions: p_name (type: string), p_mfgr (type: 
string), p_size (type: int), p_retailprice (type: double)
+                value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1409,9 +1428,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int), p_retailprice (type: double)
+              value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1543,9 +1564,11 @@ STAGE PLANS:
               sort order: +++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int), p_retailprice (type: double)
+              value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey2 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1567,9 +1590,11 @@ STAGE PLANS:
               sort order: +++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int), _col7 (type: double)
+              value expressions: _col5 (type: int), _col7 (type: double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey2 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1708,9 +1733,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int), p_retailprice (type: double)
+              value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -1854,9 +1881,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_partkey (type: int), p_name (type: string), 
p_mfgr (type: string), p_size (type: int), p_retailprice (type: double)
+              value expressions: p_partkey (type: int), p_size (type: int), 
p_retailprice (type: double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), KEY.reducesinkkey1 (type: 
string), KEY.reducesinkkey0 (type: string), VALUE._col3 (type: int), 
VALUE._col5 (type: double)
+          outputColumnNames: _col0, _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2027,9 +2056,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2205,9 +2236,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: _col0 (type: string)
               Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col0 (type: string), _col1 (type: string), 
_col2 (type: double)
+              value expressions: _col1 (type: string), _col2 (type: double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey0 (type: string), VALUE._col0 (type: 
string), VALUE._col1 (type: double)
+          outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE 
Column stats: NONE
@@ -2389,9 +2422,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int), p_retailprice (type: double)
+              value expressions: p_size (type: int), p_retailprice (type: 
double)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2690,9 +2725,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_name (type: string), p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col1 (type: string), KEY.reducesinkkey0 (type: 
string), VALUE._col4 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2714,9 +2751,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: _col2 (type: string), _col1 (type: 
string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2879,9 +2918,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: p_mfgr (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_name (type: string), p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col1 (type: string), KEY.reducesinkkey0 (type: 
string), VALUE._col4 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2901,9 +2942,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: _col2 (type: string), _col1 (type: 
string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -2923,9 +2966,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col1 (type: string), _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col1 (type: string), KEY.reducesinkkey0 (type: 
string), VALUE._col4 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3083,9 +3128,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: p_mfgr (type: string), p_name 
(type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3105,9 +3152,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col1 (type: string), _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col1 (type: string), KEY.reducesinkkey0 (type: 
string), VALUE._col4 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3266,9 +3315,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: p_mfgr (type: string), p_name 
(type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3288,9 +3339,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col1 (type: string), _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col1 (type: string), KEY.reducesinkkey0 (type: 
string), VALUE._col4 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3312,9 +3365,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: _col2 (type: string), _col1 (type: 
string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3474,9 +3529,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: p_mfgr (type: string), p_name 
(type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3498,9 +3555,11 @@ STAGE PLANS:
               sort order: ++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col1 (type: string), _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col1 (type: string), KEY.reducesinkkey0 (type: 
string), VALUE._col4 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3654,9 +3713,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: p_mfgr (type: string), p_name 
(type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: p_name (type: string), p_mfgr (type: string), 
p_size (type: int)
+              value expressions: p_size (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
@@ -3678,9 +3739,11 @@ STAGE PLANS:
               sort order: ++++
               Map-reduce partition columns: _col2 (type: string), _col1 (type: 
string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: string), 
_col5 (type: int)
+              value expressions: _col5 (type: int)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 
(type: string), VALUE._col3 (type: int)
+          outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE
           PTF Operator
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE 
Column stats: NONE


Reply via email to