You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2015/04/20 07:56:46 UTC
svn commit: r1674737 [5/9] - in
/hive/branches/cbo/ql/src/test/results/clientpositive: ./ spark/ tez/
Modified: hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf.q.out
URL: http://svn.apache.org/viewvc/hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf.q.out?rev=1674737&r1=1674736&r2=1674737&view=diff
==============================================================================
--- hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf.q.out (original)
+++ hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf.q.out Mon Apr 20 05:56:44 2015
@@ -93,28 +93,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -297,7 +297,7 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: lag_window_0
arguments: _col5, 1, _col5
name: lag
window function: GenericUDAFLagEvaluator
@@ -305,7 +305,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), (_col5 - lag_window_0) (type: int)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -571,28 +571,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -748,21 +748,21 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: lag_window_2
arguments: _col5, 1, _col5
name: lag
window function: GenericUDAFLagEvaluator
@@ -770,7 +770,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), (_col5 - lag_window_2) (type: int)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -950,21 +950,21 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: lag_window_2
arguments: _col2, 1, _col2
name: lag
window function: GenericUDAFLagEvaluator
@@ -972,7 +972,7 @@ STAGE PLANS:
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)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col2 (type: int), (_col2 - lag_window_2) (type: int)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6
Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1440,7 +1440,7 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1, _col5
name: rank
window function: GenericUDAFRankEvaluator
@@ -1448,7 +1448,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1613,28 +1613,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1786,28 +1786,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2019,28 +2019,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2202,20 +2202,20 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: count_window_0
arguments: _col5
name: count
window function: GenericUDAFCountEvaluator
window frame: PRECEDING(MAX)~
window function definition
- alias: _wcol1
+ alias: sum_window_1
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)
+ expressions: _col2 (type: string), _col1 (type: string), count_window_0 (type: bigint), sum_window_1 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2414,33 +2414,33 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: count_window_2
arguments: _col1
name: count
window function: GenericUDAFCountEvaluator
window frame: PRECEDING(MAX)~
window function definition
- alias: _wcol3
+ alias: sum_window_3
arguments: _col7
name: sum
window function: GenericUDAFSumDouble
window frame: PRECEDING(MAX)~
window function definition
- alias: _wcol4
+ alias: lag_window_4
arguments: _col5, 1, _col5
name: lag
window function: GenericUDAFLagEvaluator
@@ -2448,7 +2448,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), count_window_2 (type: bigint), _col7 (type: double), sum_window_3 (type: double), _col5 (type: int), (_col5 - lag_window_4) (type: int)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8
Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2767,14 +2767,14 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: sum_window_0
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)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: double), sum_window_0 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 13 Data size: 1573 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2954,28 +2954,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -3006,22 +3006,22 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: sum_window_0
arguments: _col5
name: sum
window function: GenericUDAFSumLong
window frame: PRECEDING(5)~
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col1 (type: string), _col2 (type: string), _col5 (type: int), _wcol0 (type: bigint)
- outputColumnNames: _col1, _col2, _col5, _wcol0
+ expressions: _col1 (type: string), _col2 (type: string), _col5 (type: int), sum_window_0 (type: bigint)
+ outputColumnNames: _col1, _col2, _col5, sum_window_0
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
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)
+ value expressions: sum_window_0 (type: bigint), _col5 (type: int)
Reducer 5
Reduce Operator Tree:
Select Operator
@@ -3042,35 +3042,35 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol1
+ alias: rank_window_1
arguments: _col3, _col2
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: dense_rank_window_2
arguments: _col3, _col2
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol3
+ alias: cume_dist_window_3
arguments: _col3, _col2
name: cume_dist
window function: GenericUDAFCumeDistEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol4
+ alias: first_value_window_4
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)
+ expressions: _col3 (type: string), _col2 (type: string), _col6 (type: int), UDFToInteger(round(_col0, 1)) (type: int), rank_window_1 (type: int), dense_rank_window_2 (type: int), cume_dist_window_3 (type: double), first_value_window_4 (type: int)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -3444,28 +3444,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col2, _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col2, _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -3710,28 +3710,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -3952,28 +3952,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -4231,28 +4231,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col2, _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col2, _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -4492,28 +4492,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col2, _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col2, _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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), _wcol2 (type: bigint)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -4740,28 +4740,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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), _wcol2 (type: bigint)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
Modified: hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf_streaming.q.out
URL: http://svn.apache.org/viewvc/hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf_streaming.q.out?rev=1674737&r1=1674736&r2=1674737&view=diff
==============================================================================
--- hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf_streaming.q.out (original)
+++ hive/branches/cbo/ql/src/test/results/clientpositive/spark/ptf_streaming.q.out Mon Apr 20 05:56:44 2015
@@ -93,28 +93,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -297,7 +297,7 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: lag_window_0
arguments: _col5, 1, _col5
name: lag
window function: GenericUDAFLagEvaluator
@@ -305,7 +305,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), (_col5 - lag_window_0) (type: int)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -615,7 +615,7 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1, _col5
name: rank
window function: GenericUDAFRankEvaluator
@@ -623,7 +623,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -788,28 +788,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1021,28 +1021,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1256,28 +1256,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1491,28 +1491,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), _col5 (type: int), rank_window_0 (type: int), dense_rank_window_1 (type: int), sum_window_2 (type: double)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1705,33 +1705,33 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: count_window_2
arguments: _col1
name: count
window function: GenericUDAFCountEvaluator
window frame: PRECEDING(MAX)~
window function definition
- alias: _wcol3
+ alias: sum_window_3
arguments: _col7
name: sum
window function: GenericUDAFSumDouble
window frame: PRECEDING(MAX)~
window function definition
- alias: _wcol4
+ alias: lag_window_4
arguments: _col5, 1, _col5
name: lag
window function: GenericUDAFLagEvaluator
@@ -1739,7 +1739,7 @@ STAGE PLANS:
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), count_window_2 (type: bigint), _col7 (type: double), sum_window_3 (type: double), _col5 (type: int), (_col5 - lag_window_4) (type: int)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8
Statistics: Num rows: 14 Data size: 1730 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -1980,28 +1980,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col2, _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col2, _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2246,28 +2246,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -2496,28 +2496,28 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col1
name: rank
window function: GenericUDAFRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol1
+ alias: dense_rank_window_1
arguments: _col1
name: dense_rank
window function: GenericUDAFDenseRankEvaluator
window frame: PRECEDING(MAX)~FOLLOWING(MAX)
isPivotResult: true
window function definition
- alias: _wcol2
+ alias: sum_window_2
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), _wcol2 (type: bigint)
+ expressions: _col2 (type: string), _col1 (type: string), rank_window_0 (type: int), dense_rank_window_1 (type: int), _col5 (type: int), sum_window_2 (type: bigint), sum_window_2 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
File Output Operator
Modified: hive/branches/cbo/ql/src/test/results/clientpositive/spark/subquery_in.q.out
URL: http://svn.apache.org/viewvc/hive/branches/cbo/ql/src/test/results/clientpositive/spark/subquery_in.q.out?rev=1674737&r1=1674736&r2=1674737&view=diff
==============================================================================
--- hive/branches/cbo/ql/src/test/results/clientpositive/spark/subquery_in.q.out (original)
+++ hive/branches/cbo/ql/src/test/results/clientpositive/spark/subquery_in.q.out Mon Apr 20 05:56:44 2015
@@ -327,7 +327,7 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col5
name: rank
window function: GenericUDAFRankEvaluator
@@ -335,7 +335,7 @@ STAGE PLANS:
isPivotResult: true
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
Filter Operator
- predicate: (_wcol0 <= 2) (type: boolean)
+ predicate: (rank_window_0 <= 2) (type: boolean)
Statistics: Num rows: 8 Data size: 968 Basic stats: COMPLETE Column stats: NONE
Select Operator
expressions: _col5 (type: int)
@@ -495,7 +495,7 @@ STAGE PLANS:
raw input shape:
window functions:
window function definition
- alias: _wcol0
+ alias: rank_window_0
arguments: _col5
name: rank
window function: GenericUDAFRankEvaluator
@@ -503,7 +503,7 @@ STAGE PLANS:
isPivotResult: true
Statistics: Num rows: 26 Data size: 3147 Basic stats: COMPLETE Column stats: NONE
Filter Operator
- predicate: ((_wcol0 <= 2) and _col2 is not null) (type: boolean)
+ predicate: ((rank_window_0 <= 2) and _col2 is not null) (type: boolean)
Statistics: Num rows: 4 Data size: 484 Basic stats: COMPLETE Column stats: NONE
Select Operator
expressions: _col2 (type: string), _col5 (type: int)