hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xu...@apache.org
Subject svn commit: r1660293 [26/48] - in /hive/branches/spark: ./ accumulo-handler/src/java/org/apache/hadoop/hive/accumulo/serde/ accumulo-handler/src/test/org/apache/hadoop/hive/accumulo/ accumulo-handler/src/test/org/apache/hadoop/hive/accumulo/mr/ accumul...
Date Tue, 17 Feb 2015 06:49:34 GMT
Modified: hive/branches/spark/ql/src/test/results/clientpositive/ptf.q.out
URL: http://svn.apache.org/viewvc/hive/branches/spark/ql/src/test/results/clientpositive/ptf.q.out?rev=1660293&r1=1660292&r2=1660293&view=diff
==============================================================================
--- hive/branches/spark/ql/src/test/results/clientpositive/ptf.q.out (original)
+++ hive/branches/spark/ql/src/test/results/clientpositive/ptf.q.out Tue Feb 17 06:49:27 2015
@@ -48,6 +48,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -72,6 +84,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: double)
@@ -220,6 +264,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: j
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: SUBQUERY
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -244,6 +300,25 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col5, 1, _col5
+                        name: lag
+                        window function: GenericUDAFLagEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
             Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), (_col5 - _wcol0) (type: int)
@@ -340,10 +415,22 @@ STAGE PLANS:
               value expressions: p_size (type: int)
       Reduce Operator Tree:
         Select Operator
-          expressions: KEY.reducesinkkey0 (type: string), KEY.reducesinkkey1 (type: string), VALUE._col3 (type: int)
-          outputColumnNames: _col2, _col1, _col5
+          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
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int)
@@ -449,6 +536,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: abc
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -473,6 +572,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: double)
@@ -586,6 +717,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -610,6 +753,39 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col5, 1, _col5
+                        name: lag
+                        window function: GenericUDAFLagEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _col5 (type: int), (_col5 - _wcol2) (type: int)
@@ -726,6 +902,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int)
@@ -781,6 +969,39 @@ STAGE PLANS:
           outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col0: string, _col1: string, _col2: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col0
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col2, 1, _col2
+                        name: lag
+                        window function: GenericUDAFLagEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
             Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int), _wcol0 (type: int), _wcol1 (type: int), _col2 (type: int), (_col2 - _wcol2) (type: int)
@@ -889,6 +1110,18 @@ STAGE PLANS:
           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
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col0: int, _col1: string, _col2: string, _col3: string, _col4: string, _col5: int, _col6: string, _col7: double, _col8: string
+                  type: TABLE
+                Partition table definition
+                  input alias: abc
+                  name: noop
+                  order by: _col1
+                  output shape: _col0: int, _col1: string, _col2: string, _col3: string, _col4: string, _col5: int, _col6: string, _col7: double, _col8: string
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Filter Operator
               predicate: _col0 is not null (type: boolean)
@@ -1028,6 +1261,18 @@ STAGE PLANS:
           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
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col0: int, _col1: string, _col2: string, _col3: string, _col4: string, _col5: int, _col6: string, _col7: double, _col8: string
+                  type: TABLE
+                Partition table definition
+                  input alias: abc
+                  name: noop
+                  order by: _col1
+                  output shape: _col0: int, _col1: string, _col2: string, _col3: string, _col4: string, _col5: int, _col6: string, _col7: double, _col8: string
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Filter Operator
               predicate: _col0 is not null (type: boolean)
@@ -1160,7 +1405,21 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             PTF Operator
+              Function definitions:
+                  Input definition
+                    input alias: part
+                    output shape: p_name: string, p_mfgr: string, p_size: int
+                    type: TABLE
+                  Partition table definition
+                    input alias: ptf_1
+                    name: noopwithmap
+                    order by: p_name, p_size(DESC)
+                    output shape: p_name: string, p_mfgr: string, p_size: int
+                    partition by: p_mfgr
+                    raw input shape:
+                    transforms raw input: true
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              Map-side function: true
               Reduce Output Operator
                 key expressions: p_mfgr (type: string), p_name (type: string), p_size (type: int)
                 sort order: ++-
@@ -1172,6 +1431,19 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noopwithmap
+                  order by: _col1, _col5(DESC)
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
+                  transforms raw input: true
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -1195,6 +1467,25 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1, _col5(DESC)
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1, _col5
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int)
@@ -1289,7 +1580,21 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             PTF Operator
+              Function definitions:
+                  Input definition
+                    input alias: part
+                    output shape: p_name: string, p_mfgr: string, p_size: int, p_retailprice: double
+                    type: TABLE
+                  Partition table definition
+                    input alias: ptf_1
+                    name: noopwithmap
+                    order by: p_name
+                    output shape: p_name: string, p_mfgr: string, p_size: int, p_retailprice: double
+                    partition by: p_mfgr
+                    raw input shape:
+                    transforms raw input: true
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              Map-side function: true
               Reduce Output Operator
                 key expressions: p_mfgr (type: string), p_name (type: string)
                 sort order: ++
@@ -1302,6 +1607,19 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noopwithmap
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
+                  transforms raw input: true
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -1326,6 +1644,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: double)
@@ -1435,6 +1785,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -1459,6 +1821,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: double)
@@ -1532,7 +1926,7 @@ dense_rank() over (partition by p_mfgr o
 sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)  as s1
 from noop(on noopwithmap(on noop(on part 
 partition by p_mfgr 
-order by p_mfgr, p_name
+order by p_mfgr DESC, p_name
 )))
 PREHOOK: type: QUERY
 POSTHOOK: query: -- 12. testFunctionChain
@@ -1543,7 +1937,7 @@ dense_rank() over (partition by p_mfgr o
 sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)  as s1
 from noop(on noopwithmap(on noop(on part 
 partition by p_mfgr 
-order by p_mfgr, p_name
+order by p_mfgr DESC, p_name
 )))
 POSTHOOK: type: QUERY
 STAGE DEPENDENCIES:
@@ -1560,20 +1954,53 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Reduce Output Operator
-              key expressions: p_mfgr (type: string), p_mfgr (type: string), p_name (type: string)
-              sort order: +++
+              key expressions: p_mfgr (type: string), p_name (type: string)
+              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_size (type: int), p_retailprice (type: double)
       Reduce Operator Tree:
         Select Operator
-          expressions: KEY.reducesinkkey2 (type: string), KEY.reducesinkkey0 (type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          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
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2(DESC), _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             PTF Operator
+              Function definitions:
+                  Input definition
+                    input alias: ptf_0
+                    output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                    type: PTFCOMPONENT
+                  Partition table definition
+                    input alias: ptf_1
+                    name: noopwithmap
+                    order by: _col2(DESC), _col1
+                    output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                    partition by: _col2
+                    raw input shape:
+                    transforms raw input: true
+                  Partition table definition
+                    input alias: ptf_2
+                    name: noop
+                    order by: _col2(DESC), _col1
+                    output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                    partition by: _col2
+                    raw input shape:
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              Map-side function: true
               File Output Operator
                 compressed: false
                 table:
@@ -1586,17 +2013,37 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: +++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              sort order: -+
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
               value expressions: _col5 (type: int), _col7 (type: double)
       Reduce Operator Tree:
         Select Operator
-          expressions: KEY.reducesinkkey2 (type: string), KEY.reducesinkkey0 (type: string), VALUE._col3 (type: int), VALUE._col5 (type: double)
+          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
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noopwithmap
+                  order by: _col2(DESC), _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
+                  transforms raw input: true
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2(DESC), _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -1621,6 +2068,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: double)
@@ -1646,7 +2125,7 @@ dense_rank() over (partition by p_mfgr o
 sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)  as s1
 from noop(on noopwithmap(on noop(on part 
 partition by p_mfgr 
-order by p_mfgr, p_name
+order by p_mfgr DESC, p_name
 )))
 PREHOOK: type: QUERY
 PREHOOK: Input: default@part
@@ -1657,7 +2136,7 @@ dense_rank() over (partition by p_mfgr o
 sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)  as s1
 from noop(on noopwithmap(on noop(on part 
 partition by p_mfgr 
-order by p_mfgr, p_name
+order by p_mfgr DESC, p_name
 )))
 POSTHOOK: type: QUERY
 POSTHOOK: Input: default@part
@@ -1740,6 +2219,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -1764,6 +2255,30 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col5
+                        name: count
+                        window function: GenericUDAFCountEvaluator
+                        window frame: PRECEDING(MAX)~
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(2)~FOLLOWING(2)
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _wcol0 (type: bigint), _wcol1 (type: double)
@@ -1888,6 +2403,18 @@ STAGE PLANS:
           outputColumnNames: _col0, _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col0: int, _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: abc
+                  name: noop
+                  order by: _col1
+                  output shape: _col0: int, _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Filter Operator
               predicate: _col0 is not null (type: boolean)
@@ -1952,6 +2479,51 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col1
+                        name: count
+                        window function: GenericUDAFCountEvaluator
+                        window frame: PRECEDING(MAX)~
+                      window function definition
+                        alias: _wcol3
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
+                      window function definition
+                        alias: _wcol4
+                        arguments: _col5, 1, _col5
+                        name: lag
+                        window function: GenericUDAFLagEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
             Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: bigint), _col7 (type: double), _wcol3 (type: double), _col5 (type: int), (_col5 - _wcol4) (type: int)
@@ -2063,6 +2635,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int)
@@ -2187,8 +2771,7 @@ POSTHOOK: type: QUERY
 STAGE DEPENDENCIES:
   Stage-1 is a root stage
   Stage-2 depends on stages: Stage-1
-  Stage-3 depends on stages: Stage-2
-  Stage-0 depends on stages: Stage-3
+  Stage-0 depends on stages: Stage-2
 
 STAGE PLANS:
   Stage: Stage-1
@@ -2210,7 +2793,7 @@ STAGE PLANS:
                 Reduce Output Operator
                   key expressions: _col0 (type: string), _col1 (type: string)
                   sort order: ++
-                  Map-reduce partition columns: _col0 (type: string), _col1 (type: string)
+                  Map-reduce partition columns: _col0 (type: string)
                   Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
                   value expressions: _col2 (type: double)
       Reduce Operator Tree:
@@ -2220,29 +2803,19 @@ STAGE PLANS:
           mode: mergepartial
           outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
-          File Output Operator
-            compressed: false
-            table:
-                input format: org.apache.hadoop.mapred.SequenceFileInputFormat
-                output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
-                serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-
-  Stage: Stage-2
-    Map Reduce
-      Map Operator Tree:
-          TableScan
-            Reduce Output Operator
-              key expressions: _col0 (type: string), _col0 (type: string)
-              sort order: ++
-              Map-reduce partition columns: _col0 (type: string)
-              Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
-              value expressions: _col1 (type: string), _col2 (type: double)
-      Reduce Operator Tree:
-        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
+            Function definitions:
+                Input definition
+                  input alias: mfgr_price_view
+                  output shape: _col0: string, _col1: string, _col2: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col0
+                  output shape: _col0: string, _col1: string, _col2: double
+                  partition by: _col0
+                  raw input shape:
             Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -2251,7 +2824,7 @@ STAGE PLANS:
                   output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
                   serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
 
-  Stage: Stage-3
+  Stage: Stage-2
     Map Reduce
       Map Operator Tree:
           TableScan
@@ -2267,6 +2840,24 @@ STAGE PLANS:
           outputColumnNames: _col0, _col1, _col2
           Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col0: string, _col1: string, _col2: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col0
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col2
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(2)~
             Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col0 (type: string), _col1 (type: string), _col2 (type: double), _wcol0 (type: double)
@@ -2429,6 +3020,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col1
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -2459,6 +3062,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5, _col7
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int, _col7: double
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col7
+                        name: sum
+                        window function: GenericUDAFSumDouble
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), _wcol0 (type: int), _wcol1 (type: int), _wcol2 (type: double)
@@ -2502,30 +3137,91 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col5
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col5
+                        name: sum
+                        window function: GenericUDAFSumLong
+                        window frame: PRECEDING(5)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
-            File Output Operator
-              compressed: false
-              table:
-                  input format: org.apache.hadoop.mapred.SequenceFileInputFormat
-                  output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
-                  serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
+            Select Operator
+              expressions: _col1 (type: string), _col2 (type: string), _col5 (type: int), _wcol0 (type: bigint)
+              outputColumnNames: _col1, _col2, _col5, _wcol0
+              Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              File Output Operator
+                compressed: false
+                table:
+                    input format: org.apache.hadoop.mapred.SequenceFileInputFormat
+                    output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
+                    serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
 
   Stage: Stage-6
     Map Reduce
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: +++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              sort order: ++
               Map-reduce partition columns: _col2 (type: string)
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
               value expressions: _wcol0 (type: bigint), _col5 (type: int)
       Reduce Operator Tree:
         Select Operator
-          expressions: VALUE._col0 (type: bigint), KEY.reducesinkkey2 (type: string), KEY.reducesinkkey0 (type: string), VALUE._col4 (type: int)
+          expressions: VALUE._col0 (type: bigint), KEY.reducesinkkey1 (type: string), KEY.reducesinkkey0 (type: string), VALUE._col4 (type: int)
           outputColumnNames: _col0, _col2, _col3, _col6
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col0: bigint, _col2: string, _col3: string, _col6: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col3, _col2
+                  partition by: _col3
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col3, _col2
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col3, _col2
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol3
+                        arguments: _col3, _col2
+                        name: cume_dist
+                        window function: GenericUDAFCumeDistEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol4
+                        arguments: _col6, true
+                        name: first_value
+                        window function: GenericUDAFFirstValueEvaluator
+                        window frame: PRECEDING(2)~FOLLOWING(2)
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col3 (type: string), _col2 (type: string), _col6 (type: int), UDFToInteger(round(_col0, 1)) (type: int), _wcol1 (type: int), _wcol2 (type: int), _wcol3 (type: double), _wcol4 (type: int)
@@ -2721,8 +3417,8 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Reduce Output Operator
-              key expressions: p_mfgr (type: string), p_mfgr (type: string)
-              sort order: ++
+              key expressions: p_mfgr (type: string)
+              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_size (type: int)
@@ -2732,9 +3428,49 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             PTF Operator
+              Function definitions:
+                  Input definition
+                    input alias: ptf_0
+                    output shape: _col1: string, _col2: string, _col5: int
+                    type: PTFCOMPONENT
+                  Partition table definition
+                    input alias: ptf_1
+                    name: noopwithmap
+                    order by: _col2, _col1
+                    output shape: _col1: string, _col2: string, _col5: int
+                    partition by: _col2, _col1
+                    raw input shape:
+                    transforms raw input: true
+                  Partition table definition
+                    input alias: ptf_2
+                    name: noop
+                    order by: _col2, _col1
+                    output shape: _col1: string, _col2: string, _col5: int
+                    partition by: _col2, _col1
+                    raw input shape:
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              Map-side function: true
               File Output Operator
                 compressed: false
                 table:
@@ -2747,8 +3483,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col1 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: ++++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              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: _col5 (type: int)
@@ -2758,6 +3494,26 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noopwithmap
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
+                  transforms raw input: true
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -2771,8 +3527,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col1 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: ++++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              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: _col5 (type: int)
@@ -2782,6 +3538,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col2, _col1
+                  partition by: _col2, _col1
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col2, _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col2, _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col5
+                        name: sum
+                        window function: GenericUDAFSumLong
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _wcol0 (type: int), _wcol1 (type: int), _col5 (type: int), _wcol2 (type: bigint)
@@ -2914,8 +3702,8 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Reduce Output Operator
-              key expressions: p_mfgr (type: string), p_mfgr (type: string)
-              sort order: ++
+              key expressions: p_mfgr (type: string)
+              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_size (type: int)
@@ -2925,6 +3713,25 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -2938,8 +3745,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col1 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: ++++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              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: _col5 (type: int)
@@ -2949,6 +3756,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -2962,8 +3781,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col2 (type: string)
-              sort order: ++
+              key expressions: _col2 (type: string)
+              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), _col5 (type: int)
@@ -2973,6 +3792,18 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -2997,6 +3828,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col5
+                        name: sum
+                        window function: GenericUDAFSumLong
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _wcol0 (type: int), _wcol1 (type: int), _col5 (type: int), _wcol2 (type: bigint)
@@ -3124,8 +3987,8 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Reduce Output Operator
-              key expressions: p_mfgr (type: string), p_name (type: string), p_mfgr (type: string), p_name (type: string)
-              sort order: ++++
+              key expressions: p_mfgr (type: string), p_name (type: string)
+              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_size (type: int)
@@ -3135,6 +3998,25 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -3148,8 +4030,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col2 (type: string)
-              sort order: ++
+              key expressions: _col2 (type: string)
+              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), _col5 (type: int)
@@ -3159,6 +4041,25 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -3183,6 +4084,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col1
+                  partition by: _col2
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col5
+                        name: sum
+                        window function: GenericUDAFSumLong
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _wcol0 (type: int), _wcol1 (type: int), _col5 (type: int), _wcol2 (type: bigint)
@@ -3311,8 +4244,8 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Reduce Output Operator
-              key expressions: p_mfgr (type: string), p_name (type: string), p_mfgr (type: string), p_name (type: string)
-              sort order: ++++
+              key expressions: p_mfgr (type: string), p_name (type: string)
+              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_size (type: int)
@@ -3322,6 +4255,25 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -3335,8 +4287,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col2 (type: string)
-              sort order: ++
+              key expressions: _col2 (type: string)
+              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), _col5 (type: int)
@@ -3346,9 +4298,35 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             PTF Operator
+              Function definitions:
+                  Input definition
+                    input alias: ptf_0
+                    output shape: _col1: string, _col2: string, _col5: int
+                    type: PTFCOMPONENT
+                  Partition table definition
+                    input alias: ptf_1
+                    name: noopwithmap
+                    order by: _col2, _col1
+                    output shape: _col1: string, _col2: string, _col5: int
+                    partition by: _col2, _col1
+                    raw input shape:
+                    transforms raw input: true
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              Map-side function: true
               File Output Operator
                 compressed: false
                 table:
@@ -3361,8 +4339,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col1 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: ++++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              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: _col5 (type: int)
@@ -3372,6 +4350,19 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noopwithmap
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
+                  transforms raw input: true
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -3385,8 +4376,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col1 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: ++++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              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: _col5 (type: int)
@@ -3396,6 +4387,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING
+                Windowing table definition
+                  input alias: ptf_1
+                  name: windowingtablefunction
+                  order by: _col2, _col1
+                  partition by: _col2, _col1
+                  raw input shape:
+                  window functions:
+                      window function definition
+                        alias: _wcol0
+                        arguments: _col2, _col1
+                        name: rank
+                        window function: GenericUDAFRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol1
+                        arguments: _col2, _col1
+                        name: dense_rank
+                        window function: GenericUDAFDenseRankEvaluator
+                        window frame: PRECEDING(MAX)~FOLLOWING(MAX)
+                        isPivotResult: true
+                      window function definition
+                        alias: _wcol2
+                        arguments: _col5
+                        name: sum
+                        window function: GenericUDAFSumLong
+                        window frame: PRECEDING(MAX)~
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Select Operator
               expressions: _col2 (type: string), _col1 (type: string), _wcol0 (type: int), _wcol1 (type: int), _col5 (type: int), _wcol2 (type: bigint)
@@ -3525,8 +4548,8 @@ STAGE PLANS:
             alias: part
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             Reduce Output Operator
-              key expressions: p_mfgr (type: string), p_name (type: string), p_mfgr (type: string), p_name (type: string)
-              sort order: ++++
+              key expressions: p_mfgr (type: string), p_name (type: string)
+              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_size (type: int)
@@ -3536,9 +4559,42 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: part
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: TABLE
+                Partition table definition
+                  input alias: ptf_1
+                  name: noop
+                  order by: _col2, _col1
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2, _col1
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             PTF Operator
+              Function definitions:
+                  Input definition
+                    input alias: ptf_0
+                    output shape: _col1: string, _col2: string, _col5: int
+                    type: PTFCOMPONENT
+                  Partition table definition
+                    input alias: ptf_1
+                    name: noopwithmap
+                    order by: _col2
+                    output shape: _col1: string, _col2: string, _col5: int
+                    partition by: _col2
+                    raw input shape:
+                    transforms raw input: true
+                  Partition table definition
+                    input alias: ptf_2
+                    name: noop
+                    order by: _col2
+                    output shape: _col1: string, _col2: string, _col5: int
+                    partition by: _col2
+                    raw input shape:
               Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
+              Map-side function: true
               File Output Operator
                 compressed: false
                 table:
@@ -3551,8 +4607,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col2 (type: string)
-              sort order: ++
+              key expressions: _col2 (type: string)
+              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), _col5 (type: int)
@@ -3562,6 +4618,26 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: PTFCOMPONENT
+                Partition table definition
+                  input alias: ptf_1
+                  name: noopwithmap
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
+                  transforms raw input: true
+                Partition table definition
+                  input alias: ptf_2
+                  name: noop
+                  order by: _col2
+                  output shape: _col1: string, _col2: string, _col5: int
+                  partition by: _col2
+                  raw input shape:
             Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
             File Output Operator
               compressed: false
@@ -3575,8 +4651,8 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             Reduce Output Operator
-              key expressions: _col2 (type: string), _col1 (type: string), _col2 (type: string), _col1 (type: string)
-              sort order: ++++
+              key expressions: _col2 (type: string), _col1 (type: string)
+              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: _col5 (type: int)
@@ -3586,6 +4662,38 @@ STAGE PLANS:
           outputColumnNames: _col1, _col2, _col5
           Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
           PTF Operator
+            Function definitions:
+                Input definition
+                  input alias: ptf_0
+                  output shape: _col1: string, _col2: string, _col5: int
+                  type: WINDOWING

[... 155 lines stripped ...]


Mime
View raw message