Modified: hive/trunk/ql/src/test/results/clientpositive/ptf_streaming.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/ptf_streaming.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/ptf_streaming.q.out (original)
+++ hive/trunk/ql/src/test/results/clientpositive/ptf_streaming.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
@@ -336,9 +340,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
@@ -475,9 +481,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
@@ -603,9 +610,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
@@ -737,9 +746,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
@@ -761,9 +772,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
@@ -897,9 +910,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
@@ -921,9 +936,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
@@ -1057,9 +1074,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
@@ -1081,9 +1100,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
@@ -1221,9 +1242,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
@@ -1417,9 +1440,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
@@ -1441,9 +1466,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
@@ -1606,9 +1633,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
@@ -1628,9 +1657,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
@@ -1650,9 +1681,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
@@ -1808,9 +1841,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
@@ -1832,9 +1867,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

Modified: hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_20.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_20.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_20.q.out 
(original)
+++ hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_20.q.out Mon Feb  
2 06:41:02 2015
@@ -57,17 +57,19 @@ STAGE PLANS:
             alias: a
             Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
             Select Operator
-              expressions: key (type: int), value (type: string), value (type: 
string)
-              outputColumnNames: _col0, _col1, _col2
+              expressions: key (type: int), value (type: string)
+              outputColumnNames: _col0, _col1
               Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
               Reduce Output Operator
                 key expressions: UDFToString(_col0) (type: string)
                 sort order: +
                 Map-reduce partition columns: UDFToString(_col0) (type: string)
                 Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
-                value expressions: _col0 (type: int), _col1 (type: string), 
_col2 (type: string)
+                value expressions: _col0 (type: int), _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), VALUE._col1 (type: string), 
VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -176,8 +178,8 @@ STAGE PLANS:
             alias: a
             Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
             Select Operator
-              expressions: value (type: string), key (type: int), value (type: 
string)
-              outputColumnNames: _col0, _col1, _col2
+              expressions: value (type: string), key (type: int)
+              outputColumnNames: _col0, _col1
               Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
               File Output Operator
                 compressed: false
@@ -298,17 +300,19 @@ STAGE PLANS:
             alias: a
             Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
             Select Operator
-              expressions: (key + key) (type: int), value (type: string), 
value (type: string)
-              outputColumnNames: _col0, _col1, _col2
+              expressions: (key + key) (type: int), value (type: string)
+              outputColumnNames: _col0, _col1
               Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
               Reduce Output Operator
                 key expressions: UDFToString(_col0) (type: string)
                 sort order: +
                 Map-reduce partition columns: UDFToString(_col0) (type: string)
                 Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
-                value expressions: _col0 (type: int), _col1 (type: string), 
_col2 (type: string)
+                value expressions: _col0 (type: int), _col1 (type: string)
       Reduce Operator Tree:
-        Extract
+        Select Operator
+          expressions: VALUE._col0 (type: int), VALUE._col1 (type: string), 
VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_21.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_21.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_21.q.out 
(original)
+++ hive/trunk/ql/src/test/results/clientpositive/smb_mapjoin_21.q.out Mon Feb  
2 06:41:02 2015
@@ -135,9 +135,11 @@ STAGE PLANS:
                 sort order: -
                 Map-reduce partition columns: _col0 (type: int)
                 Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
-                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
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -214,9 +216,10 @@ STAGE PLANS:
                 sort order: ++
                 Map-reduce partition columns: _col0 (type: int)
                 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: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey1 
(type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -293,9 +296,11 @@ STAGE PLANS:
                 sort order: +
                 Map-reduce partition columns: _col0 (type: int)
                 Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
-                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
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -372,9 +377,11 @@ STAGE PLANS:
                 sort order: +
                 Map-reduce partition columns: _col0 (type: int)
                 Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
-                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
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false
@@ -452,7 +459,9 @@ 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), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
           Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE 
Column stats: NONE
           File Output Operator
             compressed: false

Modified: hive/trunk/ql/src/test/results/clientpositive/spark/bucket2.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucket2.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/spark/bucket2.q.out (original)
+++ hive/trunk/ql/src/test/results/clientpositive/spark/bucket2.q.out Mon Feb  
2 06:41:02 2015
@@ -116,39 +116,37 @@ STAGE PLANS:
         Reducer 2 
             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/spark/bucket3.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucket3.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/spark/bucket3.q.out (original)
+++ hive/trunk/ql/src/test/results/clientpositive/spark/bucket3.q.out Mon Feb  
2 06:41:02 2015
@@ -120,42 +120,40 @@ STAGE PLANS:
         Reducer 2 
             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
-                    Static Partition Specification: ds=1/
-                    Statistics: Num rows: 500 Data size: 5312 Basic stats: 
COMPLETE Column stats: NONE
+                  NumFilesPerFileSink: 2
+                  Static Partition Specification: ds=1/
+                  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.bucket3_1
-                          partition_columns ds
-                          partition_columns.types string
-                          serialization.ddl struct bucket3_1 { i32 key, string 
value}
-                          serialization.format 1
-                          serialization.lib 
org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+                        name default.bucket3_1
+                        partition_columns ds
+                        partition_columns.types string
+                        serialization.ddl struct bucket3_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.bucket3_1
-                    TotalFiles: 2
-                    GatherStats: true
-                    MultiFileSpray: true
+                      serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+                      name: default.bucket3_1
+                  TotalFiles: 2
+                  GatherStats: true
+                  MultiFileSpray: true
 
   Stage: Stage-0
     Move Operator

Modified: hive/trunk/ql/src/test/results/clientpositive/spark/bucket4.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucket4.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/spark/bucket4.q.out (original)
+++ hive/trunk/ql/src/test/results/clientpositive/spark/bucket4.q.out Mon Feb  
2 06:41:02 2015
@@ -113,40 +113,38 @@ STAGE PLANS:
         Reducer 2 
             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:
-                          SORTBUCKETCOLSPREFIX TRUE
-                          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:
+                        SORTBUCKETCOLSPREFIX TRUE
+                        bucket_count 2
+                        bucket_field_name key
+                        columns key,value
+                        columns.comments 
+                        columns.types int:string
 #### A masked pattern was here ####
-                          name default.bucket4_1
-                          serialization.ddl struct bucket4_1 { i32 key, string 
value}
-                          serialization.format 1
-                          serialization.lib 
org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+                        name default.bucket4_1
+                        serialization.ddl struct bucket4_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.bucket4_1
-                    TotalFiles: 2
-                    GatherStats: true
-                    MultiFileSpray: true
+                      serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+                      name: default.bucket4_1
+                  TotalFiles: 2
+                  GatherStats: true
+                  MultiFileSpray: true
 
   Stage: Stage-0
     Move Operator

Modified: 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_2.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_2.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_2.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_2.q.out
 Mon Feb  2 06:41:02 2015
@@ -153,12 +153,14 @@ STAGE PLANS:
                           sort order: +
                           Map-reduce partition columns: _col0 (type: int)
                           Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
string)
+                          value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -323,12 +325,14 @@ STAGE PLANS:
                           sort order: +
                           Map-reduce partition columns: _col0 (type: int)
                           Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
string)
+                          value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -517,12 +521,14 @@ STAGE PLANS:
                           sort order: +
                           Map-reduce partition columns: _col0 (type: int)
                           Statistics: Num rows: 92 Data size: 809 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
string)
+                          value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 92 Data size: 809 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -723,12 +729,14 @@ STAGE PLANS:
                             sort order: +
                             Map-reduce partition columns: _col0 (type: int)
                             Statistics: Num rows: 46 Data size: 404 Basic 
stats: COMPLETE Column stats: NONE
-                            value expressions: _col0 (type: int), _col1 (type: 
string)
+                            value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -911,12 +919,14 @@ STAGE PLANS:
                             sort order: +
                             Map-reduce partition columns: _col0 (type: int)
                             Statistics: Num rows: 46 Data size: 404 Basic 
stats: COMPLETE Column stats: NONE
-                            value expressions: _col0 (type: int), _col1 (type: 
string)
+                            value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -1099,12 +1109,14 @@ STAGE PLANS:
                             sort order: +
                             Map-reduce partition columns: _col0 (type: int)
                             Statistics: Num rows: 46 Data size: 404 Basic 
stats: COMPLETE Column stats: NONE
-                            value expressions: _col0 (type: int), _col1 (type: 
string)
+                            value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_4.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_4.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_4.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_4.q.out
 Mon Feb  2 06:41:02 2015
@@ -121,20 +121,22 @@ STAGE PLANS:
                         0 Map 1
                       Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
                       Select Operator
-                        expressions: _col0 (type: int), _col0 (type: int), 
concat(_col1, _col7) (type: string)
-                        outputColumnNames: _col0, _col1, _col2
+                        expressions: _col0 (type: int), concat(_col1, _col7) 
(type: string)
+                        outputColumnNames: _col1, _col2
                         Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
                         Reduce Output Operator
                           key expressions: _col1 (type: int)
                           sort order: +
                           Map-reduce partition columns: _col1 (type: int)
                           Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey0 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -314,12 +316,14 @@ STAGE PLANS:
                         sort order: +
                         Map-reduce partition columns: _col1 (type: string)
                         Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                        value expressions: _col0 (type: int), _col1 (type: 
string)
+                        value expressions: _col0 (type: int)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: VALUE._col0 (type: int), KEY.reducesinkkey0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_6.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_6.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_6.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_6.q.out
 Mon Feb  2 06:41:02 2015
@@ -131,12 +131,14 @@ STAGE PLANS:
                           sort order: +-
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -308,12 +310,14 @@ STAGE PLANS:
                           sort order: +-
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -485,12 +489,14 @@ STAGE PLANS:
                           sort order: +-
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -597,12 +603,14 @@ STAGE PLANS:
                           sort order: +-
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -715,12 +723,14 @@ STAGE PLANS:
                           sort order: +-
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -910,12 +920,14 @@ STAGE PLANS:
                           sort order: +-
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -1115,12 +1127,14 @@ STAGE PLANS:
                           sort order: --
                           Map-reduce partition columns: _col0 (type: int), 
_col1 (type: int)
                           Statistics: Num rows: 23 Data size: 268 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col2 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), 
KEY.reducesinkkey1 (type: int), VALUE._col0 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 23 Data size: 268 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_7.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_7.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_7.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_7.q.out
 Mon Feb  2 06:41:02 2015
@@ -131,12 +131,14 @@ STAGE PLANS:
                           sort order: +
                           Map-reduce partition columns: _col0 (type: int)
                           Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
string)
+                          value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -311,12 +313,14 @@ STAGE PLANS:
                             sort order: +
                             Map-reduce partition columns: _col0 (type: int)
                             Statistics: Num rows: 46 Data size: 404 Basic 
stats: COMPLETE Column stats: NONE
-                            value expressions: _col0 (type: int), _col1 (type: 
string)
+                            value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -497,12 +501,14 @@ STAGE PLANS:
                             sort order: +
                             Map-reduce partition columns: _col0 (type: int)
                             Statistics: Num rows: 15 Data size: 134 Basic 
stats: COMPLETE Column stats: NONE
-                            value expressions: _col0 (type: int), _col1 (type: 
string)
+                            value expressions: _col1 (type: string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: string)
+                outputColumnNames: _col0, _col1
                 Statistics: Num rows: 15 Data size: 134 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_8.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_8.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_8.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/spark/bucketsortoptimize_insert_8.q.out
 Mon Feb  2 06:41:02 2015
@@ -129,12 +129,14 @@ STAGE PLANS:
                           sort order: +
                           Map-reduce partition columns: _col0 (type: int)
                           Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col1 (type: int), _col2 (type: 
string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: int), VALUE._col1 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false
@@ -300,12 +302,14 @@ STAGE PLANS:
                           sort order: +
                           Map-reduce partition columns: _col0 (type: int)
                           Statistics: Num rows: 46 Data size: 404 Basic stats: 
COMPLETE Column stats: NONE
-                          value expressions: _col0 (type: int), _col1 (type: 
int), _col2 (type: string)
+                          value expressions: _col1 (type: int), _col2 (type: 
string)
             Local Work:
               Map Reduce Local Work
         Reducer 3 
             Reduce Operator Tree:
-              Extract
+              Select Operator
+                expressions: KEY.reducesinkkey0 (type: int), VALUE._col0 
(type: int), VALUE._col1 (type: string)
+                outputColumnNames: _col0, _col1, _col2
                 Statistics: Num rows: 46 Data size: 404 Basic stats: COMPLETE 
Column stats: NONE
                 File Output Operator
                   compressed: false

Modified: 
hive/trunk/ql/src/test/results/clientpositive/spark/disable_merge_for_bucketing.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/disable_merge_for_bucketing.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- 
hive/trunk/ql/src/test/results/clientpositive/spark/disable_merge_for_bucketing.q.out
 (original)
+++ 
hive/trunk/ql/src/test/results/clientpositive/spark/disable_merge_for_bucketing.q.out
 Mon Feb  2 06:41:02 2015
@@ -112,39 +112,37 @@ STAGE PLANS:
         Reducer 2 
             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/spark/load_dyn_part2.q.out
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/spark/load_dyn_part2.q.out?rev=1656393&r1=1656392&r2=1656393&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/spark/load_dyn_part2.q.out 
(original)
+++ hive/trunk/ql/src/test/results/clientpositive/spark/load_dyn_part2.q.out 
Mon Feb  2 06:41:02 2015
@@ -66,7 +66,9 @@ STAGE PLANS:
                       value expressions: _col0 (type: string), _col1 (type: 
string), _col2 (type: string)
         Reducer 2 
             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


Reply via email to