Repository: hive
Updated Branches:
  refs/heads/master 3db7227fc -> be9735e10


http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out 
b/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out
index 078c07c..1d75d04 100644
--- a/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out
+++ b/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out
@@ -51,14 +51,14 @@ struct('ten','1')
 )
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_2]
-         outputColumnNames:["_col0","_col1"]
-         Filter Operator [FIL_4]
-            predicate:(struct(id,lineid)) IN (const struct('two','3'), const 
struct('three','1'), const struct('one','1'), const struct('five','2'), const 
struct('six','1'), const struct('eight','1'), const struct('seven','1'), const 
struct('nine','1'), const struct('ten','1')) (type: boolean)
-            TableScan [TS_0]
-               alias:test_1
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_2]
+      Output:["_col0","_col1"]
+      Filter Operator [FIL_4]
+        predicate:(struct(id,lineid)) IN (const struct('two','3'), const 
struct('three','1'), const struct('one','1'), const struct('five','2'), const 
struct('six','1'), const struct('eight','1'), const struct('seven','1'), const 
struct('nine','1'), const struct('ten','1'))
+        TableScan [TS_0]
+          Output:["id","lineid"]
 
 PREHOOK: query: select * from test_1 where struct(`id`, `lineid`)
 IN (
@@ -121,12 +121,12 @@ struct('ten','1')
 ) as b from test_1
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_1]
-         outputColumnNames:["_col0","_col1","_col2"]
-         TableScan [TS_0]
-            alias:test_1
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_1]
+      Output:["_col0","_col1","_col2"]
+      TableScan [TS_0]
+        Output:["id","lineid"]
 
 PREHOOK: query: select `id`, `lineid`, struct(`id`, `lineid`)
 IN (
@@ -209,14 +209,14 @@ struct(10,1)
 )
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_2]
-         outputColumnNames:["_col0","_col1"]
-         Filter Operator [FIL_4]
-            predicate:(struct(id,lineid)) IN (const struct(2,3), const 
struct(3,1), const struct(1,1), const struct(5,2), const struct(6,1), const 
struct(8,1), const struct(7,1), const struct(9,1), const struct(10,1)) (type: 
boolean)
-            TableScan [TS_0]
-               alias:test_2
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_2]
+      Output:["_col0","_col1"]
+      Filter Operator [FIL_4]
+        predicate:(struct(id,lineid)) IN (const struct(2,3), const 
struct(3,1), const struct(1,1), const struct(5,2), const struct(6,1), const 
struct(8,1), const struct(7,1), const struct(9,1), const struct(10,1))
+        TableScan [TS_0]
+          Output:["id","lineid"]
 
 PREHOOK: query: select * from test_2 where struct(`id`, `lineid`)
 IN (
@@ -279,12 +279,12 @@ struct(10,1)
 ) as b from test_2
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_1]
-         outputColumnNames:["_col0","_col1","_col2"]
-         TableScan [TS_0]
-            alias:test_2
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_1]
+      Output:["_col0","_col1","_col2"]
+      TableScan [TS_0]
+        Output:["id","lineid"]
 
 PREHOOK: query: select `id`, `lineid`, struct(`id`, `lineid`)
 IN (
@@ -367,14 +367,14 @@ struct('ten',1)
 )
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_2]
-         outputColumnNames:["_col0","_col1"]
-         Filter Operator [FIL_4]
-            predicate:(struct(id,lineid)) IN (const struct('two',3), const 
struct('three',1), const struct('one',1), const struct('five',2), const 
struct('six',1), const struct('eight',1), const struct('seven',1), const 
struct('nine',1), const struct('ten',1)) (type: boolean)
-            TableScan [TS_0]
-               alias:test_3
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_2]
+      Output:["_col0","_col1"]
+      Filter Operator [FIL_4]
+        predicate:(struct(id,lineid)) IN (const struct('two',3), const 
struct('three',1), const struct('one',1), const struct('five',2), const 
struct('six',1), const struct('eight',1), const struct('seven',1), const 
struct('nine',1), const struct('ten',1))
+        TableScan [TS_0]
+          Output:["id","lineid"]
 
 PREHOOK: query: select * from test_3 where struct(`id`, `lineid`)
 IN (
@@ -437,12 +437,12 @@ struct('ten',1)
 ) as b from test_3
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_1]
-         outputColumnNames:["_col0","_col1","_col2"]
-         TableScan [TS_0]
-            alias:test_3
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_1]
+      Output:["_col0","_col1","_col2"]
+      TableScan [TS_0]
+        Output:["id","lineid"]
 
 PREHOOK: query: select `id`, `lineid`, struct(`id`, `lineid`)
 IN (
@@ -528,14 +528,14 @@ struct(3L, "b", 1.5)
 )
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_2]
-         outputColumnNames:["_col0","_col1","_col2"]
-         Filter Operator [FIL_4]
-            predicate:(struct(my_bigint,my_string,my_double)) IN (const 
struct(1,'a',1.5), const struct(1,'b',-0.5), const struct(3,'b',1.5), const 
struct(1,'d',1.5), const struct(1,'c',1.5), const struct(1,'b',2.5), const 
struct(1,'b',0.5), const struct(5,'b',1.5), const struct(1,'a',0.5), const 
struct(3,'b',1.5)) (type: boolean)
-            TableScan [TS_0]
-               alias:test_4
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_2]
+      Output:["_col0","_col1","_col2"]
+      Filter Operator [FIL_4]
+        predicate:(struct(my_bigint,my_string,my_double)) IN (const 
struct(1,'a',1.5), const struct(1,'b',-0.5), const struct(3,'b',1.5), const 
struct(1,'d',1.5), const struct(1,'c',1.5), const struct(1,'b',2.5), const 
struct(1,'b',0.5), const struct(5,'b',1.5), const struct(1,'a',0.5), const 
struct(3,'b',1.5))
+        TableScan [TS_0]
+          Output:["my_bigint","my_string","my_double"]
 
 PREHOOK: query: select * from test_4 where struct(`my_bigint`, `my_string`, 
`my_double`)
 IN (
@@ -601,12 +601,12 @@ struct(3L, "b", 1.5)
 ) as b from test_4
 POSTHOOK: type: QUERY
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_1]
-         outputColumnNames:["_col0","_col1","_col2","_col3"]
-         TableScan [TS_0]
-            alias:test_4
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_1]
+      Output:["_col0","_col1","_col2","_col3"]
+      TableScan [TS_0]
+        Output:["my_bigint","my_string","my_double"]
 
 PREHOOK: query: select `my_bigint`, `my_string`, `my_double`, 
struct(`my_bigint`, `my_string`, `my_double`)
 IN (

http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out
----------------------------------------------------------------------
diff --git 
a/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out 
b/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out
index 0cb2270..8355381 100644
--- a/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out
+++ b/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out
@@ -130,12 +130,12 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_1]
-         
outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"]
-         TableScan [TS_0]
-            alias:parquet_types
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_1]
+      
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"]
+      TableScan [TS_0]
+        
Output:["cint","ctinyint","csmallint","cfloat","cdouble","cstring1","t","cchar","cvarchar","cbinary","cdecimal"]
 
 PREHOOK: query: SELECT cint, ctinyint, csmallint, cfloat, cdouble, cstring1, 
t, cchar, cvarchar,
 hex(cbinary), cdecimal FROM parquet_types
@@ -178,12 +178,12 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_1]
-         outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"]
-         TableScan [TS_0]
-            alias:parquet_types
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_1]
+      Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
+      TableScan [TS_0]
+        Output:["cchar","cvarchar","cdecimal"]
 
 PREHOOK: query: SELECT cchar, LENGTH(cchar), cvarchar, LENGTH(cvarchar), 
cdecimal, SIGN(cdecimal) FROM parquet_types
 PREHOOK: type: QUERY
@@ -246,46 +246,26 @@ Reducer 2 <- Map 1 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 3 vectorized
-         File Output Operator [FS_10]
-            compressed:false
-            Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE 
Column stats: NONE
-            table:{"input 
format:":"org.apache.hadoop.mapred.TextInputFormat","output 
format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"}
-            Select Operator [OP_9]
-            |  
outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
-            |  Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE 
Column stats: NONE
-            |<-Reducer 2 [SIMPLE_EDGE]
-               Reduce Output Operator [RS_6]
-                  key expressions:_col0 (type: tinyint)
-                  sort order:+
-                  Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE 
Column stats: NONE
-                  value expressions:_col1 (type: int), _col2 (type: smallint), 
_col3 (type: bigint), _col4 (type: double), _col5 (type: double), _col6 (type: 
decimal(4,2))
-                  Group By Operator [GBY_4]
-                  |  
aggregations:["max(VALUE._col0)","min(VALUE._col1)","count(VALUE._col2)","avg(VALUE._col3)","stddev_pop(VALUE._col4)","max(VALUE._col5)"]
-                  |  keys:KEY._col0 (type: tinyint)
-                  |  
outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
-                  |  Statistics:Num rows: 11 Data size: 121 Basic stats: 
COMPLETE Column stats: NONE
-                  |<-Map 1 [SIMPLE_EDGE]
-                     Reduce Output Operator [RS_3]
-                        key expressions:_col0 (type: tinyint)
-                        Map-reduce partition columns:_col0 (type: tinyint)
-                        sort order:+
-                        Statistics:Num rows: 22 Data size: 242 Basic stats: 
COMPLETE Column stats: NONE
-                        value expressions:_col1 (type: int), _col2 (type: 
smallint), _col3 (type: bigint), _col4 (type: 
struct<count:bigint,sum:double,input:float>), _col5 (type: 
struct<count:bigint,sum:double,variance:double>), _col6 (type: decimal(4,2))
-                        Group By Operator [GBY_2]
-                           
aggregations:["max(cint)","min(csmallint)","count(cstring1)","avg(cfloat)","stddev_pop(cdouble)","max(cdecimal)"]
-                           keys:ctinyint (type: tinyint)
-                           
outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
-                           Statistics:Num rows: 22 Data size: 242 Basic stats: 
COMPLETE Column stats: NONE
-                           Select Operator [SEL_1]
-                              
outputColumnNames:["ctinyint","cint","csmallint","cstring1","cfloat","cdouble","cdecimal"]
-                              Statistics:Num rows: 22 Data size: 242 Basic 
stats: COMPLETE Column stats: NONE
-                              TableScan [TS_0]
-                                 alias:parquet_types
-                                 Statistics:Num rows: 22 Data size: 242 Basic 
stats: COMPLETE Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 3 vectorized
+      File Output Operator [FS_10]
+        Select Operator [OP_9] (rows=11 width=11)
+          Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
+        <-Reducer 2 [SIMPLE_EDGE]
+          SHUFFLE [RS_6]
+            Group By Operator [GBY_4] (rows=11 width=11)
+              
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["max(VALUE._col0)","min(VALUE._col1)","count(VALUE._col2)","avg(VALUE._col3)","stddev_pop(VALUE._col4)","max(VALUE._col5)"],keys:KEY._col0
+            <-Map 1 [SIMPLE_EDGE]
+              SHUFFLE [RS_3]
+                PartitionCols:_col0
+                Group By Operator [GBY_2] (rows=22 width=11)
+                  
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["max(cint)","min(csmallint)","count(cstring1)","avg(cfloat)","stddev_pop(cdouble)","max(cdecimal)"],keys:ctinyint
+                  Select Operator [SEL_1] (rows=22 width=11)
+                    
Output:["ctinyint","cint","csmallint","cstring1","cfloat","cdouble","cdecimal"]
+                    TableScan [TS_0] (rows=22 width=11)
+                      
default@parquet_types,parquet_types,Tbl:COMPLETE,Col:NONE,Output:["cint","ctinyint","csmallint","cfloat","cdouble","cstring1","cdecimal"]
 
 PREHOOK: query: SELECT ctinyint,
   MAX(cint),

http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out
----------------------------------------------------------------------
diff --git 
a/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out 
b/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out
index 8f9b305..d8f21e0 100644
--- 
a/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out
+++ 
b/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out
@@ -37,14 +37,14 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_2]
-         
outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"]
-         Filter Operator [FIL_4]
-            predicate:((cbigint % 250) = 0) (type: boolean)
-            TableScan [TS_0]
-               alias:alltypesorc
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_2]
+      
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"]
+      Filter Operator [FIL_4]
+        predicate:((cbigint % 250) = 0)
+        TableScan [TS_0]
+          
Output:["ctinyint","csmallint","cint","cbigint","cfloat","cdouble","cstring1","ctimestamp1","cboolean1"]
 
 PREHOOK: query: select
 -- to timestamp
@@ -149,14 +149,14 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Select Operator [SEL_2]
-         
outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"]
-         Filter Operator [FIL_4]
-            predicate:((cbigint % 250) = 0) (type: boolean)
-            TableScan [TS_0]
-               alias:alltypesorc
+  Fetch Operator
+    limit:-1
+    Select Operator [SEL_2]
+      
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"]
+      Filter Operator [FIL_4]
+        predicate:((cbigint % 250) = 0)
+        TableScan [TS_0]
+          
Output:["ctinyint","csmallint","cint","cbigint","cfloat","cdouble","cstring1","ctimestamp1","cboolean1"]
 
 PREHOOK: query: select
 -- to timestamp

http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/windowing_gby.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/tez/windowing_gby.q.out 
b/ql/src/test/results/clientpositive/tez/windowing_gby.q.out
index 72d1f14..2af3e58 100644
--- a/ql/src/test/results/clientpositive/tez/windowing_gby.q.out
+++ b/ql/src/test/results/clientpositive/tez/windowing_gby.q.out
@@ -18,88 +18,49 @@ Reducer 3 <- Reducer 2 (SIMPLE_EDGE)
 Reducer 4 <- Reducer 3 (SIMPLE_EDGE)
 
 Stage-0
-   Fetch Operator
-      limit:-1
-      Stage-1
-         Reducer 4
-         File Output Operator [FS_19]
-            compressed:false
-            Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE 
Column stats: NONE
-            table:{"input 
format:":"org.apache.hadoop.mapred.TextInputFormat","output 
format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"}
-            Select Operator [SEL_17]
-               outputColumnNames:["_col0"]
-               Statistics:Num rows: 6758 Data size: 1453080 Basic stats: 
COMPLETE Column stats: NONE
-               PTF Operator [PTF_16]
-                  Function definitions:[{"Input 
definition":{"type:":"WINDOWING"}},{"name:":"windowingtablefunction","order 
by:":"(UDFToDouble(_col1) / UDFToDouble(_col2))","partition by:":"0"}]
-                  Statistics:Num rows: 6758 Data size: 1453080 Basic stats: 
COMPLETE Column stats: NONE
-                  Select Operator [SEL_15]
-                  |  outputColumnNames:["_col1","_col2"]
-                  |  Statistics:Num rows: 6758 Data size: 1453080 Basic stats: 
COMPLETE Column stats: NONE
-                  |<-Reducer 3 [SIMPLE_EDGE]
-                     Reduce Output Operator [RS_14]
-                        key expressions:0 (type: int), (UDFToDouble(_col1) / 
UDFToDouble(_col2)) (type: double)
-                        Map-reduce partition columns:0 (type: int)
-                        sort order:++
-                        Statistics:Num rows: 6758 Data size: 1453080 Basic 
stats: COMPLETE Column stats: NONE
-                        value expressions:_col1 (type: bigint), _col2 (type: 
bigint)
-                        Select Operator [SEL_13]
-                           outputColumnNames:["_col1","_col2"]
-                           Statistics:Num rows: 6758 Data size: 1453080 Basic 
stats: COMPLETE Column stats: NONE
-                           Group By Operator [GBY_12]
-                           |  
aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"]
-                           |  keys:KEY._col0 (type: boolean)
-                           |  outputColumnNames:["_col0","_col1","_col2"]
-                           |  Statistics:Num rows: 6758 Data size: 1453080 
Basic stats: COMPLETE Column stats: NONE
-                           |<-Reducer 2 [SIMPLE_EDGE]
-                              Reduce Output Operator [RS_11]
-                                 key expressions:_col0 (type: boolean)
-                                 Map-reduce partition columns:_col0 (type: 
boolean)
-                                 sort order:+
-                                 Statistics:Num rows: 13516 Data size: 2906160 
Basic stats: COMPLETE Column stats: NONE
-                                 value expressions:_col1 (type: bigint), _col2 
(type: bigint)
-                                 Group By Operator [GBY_10]
-                                    aggregations:["sum(_col3)","sum(_col1)"]
-                                    keys:_col2 (type: boolean)
-                                    outputColumnNames:["_col0","_col1","_col2"]
-                                    Statistics:Num rows: 13516 Data size: 
2906160 Basic stats: COMPLETE Column stats: NONE
-                                    Select Operator [SEL_9]
-                                       
outputColumnNames:["_col2","_col3","_col1"]
-                                       Statistics:Num rows: 13516 Data size: 
2906160 Basic stats: COMPLETE Column stats: NONE
-                                       Merge Join Operator [MERGEJOIN_24]
-                                       |  condition map:[{"":"Inner Join 0 to 
1"}]
-                                       |  keys:{"0":"_col0 (type: 
string)","1":"_col1 (type: string)"}
-                                       |  
outputColumnNames:["_col1","_col2","_col3"]
-                                       |  Statistics:Num rows: 13516 Data 
size: 2906160 Basic stats: COMPLETE Column stats: NONE
-                                       |<-Map 1 [SIMPLE_EDGE]
-                                       |  Reduce Output Operator [RS_6]
-                                       |     key expressions:_col0 (type: 
string)
-                                       |     Map-reduce partition 
columns:_col0 (type: string)
-                                       |     sort order:+
-                                       |     Statistics:Num rows: 20 Data 
size: 262 Basic stats: COMPLETE Column stats: NONE
-                                       |     value expressions:_col1 (type: 
int), _col2 (type: boolean)
-                                       |     Select Operator [SEL_2]
-                                       |        
outputColumnNames:["_col0","_col1","_col2"]
-                                       |        Statistics:Num rows: 20 Data 
size: 262 Basic stats: COMPLETE Column stats: NONE
-                                       |        Filter Operator [FIL_22]
-                                       |           predicate:value is not null 
(type: boolean)
-                                       |           Statistics:Num rows: 20 
Data size: 262 Basic stats: COMPLETE Column stats: NONE
-                                       |           TableScan [TS_0]
-                                       |              alias:ws
-                                       |              Statistics:Num rows: 20 
Data size: 262 Basic stats: COMPLETE Column stats: NONE
-                                       |<-Map 5 [SIMPLE_EDGE]
-                                          Reduce Output Operator [RS_7]
-                                             key expressions:_col1 (type: 
string)
-                                             Map-reduce partition 
columns:_col1 (type: string)
-                                             sort order:+
-                                             Statistics:Num rows: 12288 Data 
size: 2641964 Basic stats: COMPLETE Column stats: NONE
-                                             value expressions:_col0 (type: 
int)
-                                             Select Operator [SEL_5]
-                                                
outputColumnNames:["_col0","_col1"]
-                                                Statistics:Num rows: 12288 
Data size: 2641964 Basic stats: COMPLETE Column stats: NONE
-                                                Filter Operator [FIL_23]
-                                                   predicate:cstring1 is not 
null (type: boolean)
-                                                   Statistics:Num rows: 12288 
Data size: 2641964 Basic stats: COMPLETE Column stats: NONE
-                                                   TableScan [TS_3]
-                                                      alias:wr
-                                                      Statistics:Num rows: 
12288 Data size: 2641964 Basic stats: COMPLETE Column stats: NONE
+  Fetch Operator
+    limit:-1
+    Stage-1
+      Reducer 4
+      File Output Operator [FS_19]
+        Select Operator [SEL_17] (rows=6758 width=215)
+          Output:["_col0"]
+          PTF Operator [PTF_16] (rows=6758 width=215)
+            Function definitions:[{},{"name:":"windowingtablefunction","order 
by:":"(UDFToDouble(_col1) / UDFToDouble(_col2))","partition by:":"0"}]
+            Select Operator [SEL_15] (rows=6758 width=215)
+              Output:["_col1","_col2"]
+            <-Reducer 3 [SIMPLE_EDGE]
+              SHUFFLE [RS_14]
+                PartitionCols:0
+                Select Operator [SEL_13] (rows=6758 width=215)
+                  Output:["_col1","_col2"]
+                  Group By Operator [GBY_12] (rows=6758 width=215)
+                    
Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0
+                  <-Reducer 2 [SIMPLE_EDGE]
+                    SHUFFLE [RS_11]
+                      PartitionCols:_col0
+                      Group By Operator [GBY_10] (rows=13516 width=215)
+                        
Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)","sum(_col1)"],keys:_col2
+                        Select Operator [SEL_9] (rows=13516 width=215)
+                          Output:["_col2","_col3","_col1"]
+                          Merge Join Operator [MERGEJOIN_24] (rows=13516 
width=215)
+                            
Conds:RS_6._col0=RS_7._col1(Inner),Output:["_col1","_col2","_col3"]
+                          <-Map 1 [SIMPLE_EDGE]
+                            SHUFFLE [RS_6]
+                              PartitionCols:_col0
+                              Select Operator [SEL_2] (rows=20 width=13)
+                                Output:["_col0","_col1","_col2"]
+                                Filter Operator [FIL_22] (rows=20 width=13)
+                                  predicate:value is not null
+                                  TableScan [TS_0] (rows=20 width=13)
+                                    
default@cbo_t3,ws,Tbl:COMPLETE,Col:NONE,Output:["value","c_int","c_boolean"]
+                          <-Map 5 [SIMPLE_EDGE]
+                            SHUFFLE [RS_7]
+                              PartitionCols:_col1
+                              Select Operator [SEL_5] (rows=12288 width=215)
+                                Output:["_col0","_col1"]
+                                Filter Operator [FIL_23] (rows=12288 width=215)
+                                  predicate:cstring1 is not null
+                                  TableScan [TS_3] (rows=12288 width=215)
+                                    
default@alltypesorc,wr,Tbl:COMPLETE,Col:NONE,Output:["cint","cstring1"]
 

Reply via email to