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 2013/03/09 07:07:39 UTC
svn commit: r1454661 [1/2] - in /hive/branches/ptf-windowing/ql/src:
java/org/apache/hadoop/hive/ql/parse/ test/queries/clientnegative/
test/queries/clientpositive/ test/results/clientnegative/
test/results/clientpositive/
Author: hashutosh
Date: Sat Mar 9 06:07:38 2013
New Revision: 1454661
URL: http://svn.apache.org/r1454661
Log:
HIVE-4140
Summary: Specifying alias for windowing function. Also moved windowing rules from FromClauseParser.g to SelectClauseParser.g
Test Plan: Updated existing tests.
Reviewers: hbutani
Differential Revision: https://reviews.facebook.net/D9249
Modified:
hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/FromClauseParser.g
hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/SelectClauseParser.g
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_AmbiguousWindowDefn.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DistributeByOrderBy.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DuplicateWindowAlias.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleDistributeClause.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleOrderInWindowDefs.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatiblePartitionInWindowDefs.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleSortClause.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_InvalidValueBoundary.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_PartitionBySortBy.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries.q
hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries2.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag_queries.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_rcfile.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_seqfile.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_columnPruning.q
hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_expressions.q
hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_DistributeByOrderBy.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_PartitionBySortBy.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries2.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag_queries.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_rcfile.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_seqfile.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/windowing.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/windowing_columnPruning.q.out
hive/branches/ptf-windowing/ql/src/test/results/clientpositive/windowing_expressions.q.out
Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/FromClauseParser.g
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/FromClauseParser.g?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/FromClauseParser.g (original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/FromClauseParser.g Sat Mar 9 06:07:38 2013
@@ -232,68 +232,6 @@ partitionedTableFunction
-> ^(TOK_PTBLFUNCTION $name $alias? partitionTableFunctionSource partitioningSpec? expression*)
;
-//---------------------- Rules for windowing clauses -------------------------------
-window_clause
-@init { gParent.msgs.push("window_clause"); }
-@after { gParent.msgs.pop(); }
-:
- KW_WINDOW window_defn (COMMA window_defn)* -> ^(KW_WINDOW window_defn+)
-;
-
-window_defn
-@init { gParent.msgs.push("window_defn"); }
-@after { gParent.msgs.pop(); }
-:
- Identifier KW_AS window_specification -> ^(TOK_WINDOWDEF Identifier window_specification)
-;
-
-window_specification
-@init { gParent.msgs.push("window_specification"); }
-@after { gParent.msgs.pop(); }
-:
- (Identifier | ( LPAREN Identifier? partitioningSpec? window_frame? RPAREN)) -> ^(TOK_WINDOWSPEC Identifier? partitioningSpec? window_frame?)
-;
-
-window_frame :
- window_range_expression |
- window_value_expression
-;
-
-window_range_expression
-@init { gParent.msgs.push("window_range_expression"); }
-@after { gParent.msgs.pop(); }
-:
- KW_ROWS KW_UNBOUNDED KW_PRECEDING -> ^(TOK_WINDOWRANGE ^(KW_PRECEDING KW_UNBOUNDED) ^(KW_CURRENT)) |
- KW_ROWS KW_BETWEEN s=rowsboundary KW_AND end=rowsboundary -> ^(TOK_WINDOWRANGE $s $end)
-;
-
-rowsboundary
-@init { gParent.msgs.push("rowsboundary"); }
-@after { gParent.msgs.pop(); }
-:
- KW_UNBOUNDED (r=KW_PRECEDING|r=KW_FOLLOWING) -> ^($r KW_UNBOUNDED) |
- KW_CURRENT KW_ROW -> ^(KW_CURRENT) |
- Number (d=KW_PRECEDING | d=KW_FOLLOWING ) -> ^($d Number)
-;
-
-window_value_expression
-@init { gParent.msgs.push("window_value_expression"); }
-@after { gParent.msgs.pop(); }
-:
- KW_RANGE KW_UNBOUNDED KW_PRECEDING -> ^(TOK_WINDOWVALUES ^(KW_PRECEDING KW_UNBOUNDED) ^(KW_CURRENT)) |
- KW_RANGE KW_BETWEEN s=valuesboundary KW_AND end=valuesboundary -> ^(TOK_WINDOWVALUES $s $end)
-;
-
-valuesboundary
-@init { gParent.msgs.push("valuesboundary"); }
-@after { gParent.msgs.pop(); }
-:
- KW_UNBOUNDED (r=KW_PRECEDING|r=KW_FOLLOWING) -> ^($r KW_UNBOUNDED) |
- KW_CURRENT KW_ROW -> ^(KW_CURRENT) |
- rowExp=expression rngExp=Number (d=KW_LESS | d=KW_MORE ) -> ^($d $rowExp $rngExp)
-;
-
-
//----------------------- Rules for parsing whereClause -----------------------------
// where a=b and ...
whereClause
Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/SelectClauseParser.g
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/SelectClauseParser.g?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/SelectClauseParser.g (original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/SelectClauseParser.g Sat Mar 9 06:07:38 2013
@@ -125,9 +125,8 @@ selectItem
@init { gParent.msgs.push("selection target"); }
@after { gParent.msgs.pop(); }
:
- ( selectExpression
+ ( selectExpression (KW_OVER ws=window_specification )?
((KW_AS? identifier) | (KW_AS LPAREN identifier (COMMA identifier)* RPAREN))?
- (KW_OVER ws=window_specification )?
) -> ^(TOK_SELEXPR selectExpression identifier* $ws?)
;
@@ -158,3 +157,66 @@ selectExpressionList
selectExpression (COMMA selectExpression)* -> ^(TOK_EXPLIST selectExpression+)
;
+//---------------------- Rules for windowing clauses -------------------------------
+window_clause
+@init { gParent.msgs.push("window_clause"); }
+@after { gParent.msgs.pop(); }
+:
+ KW_WINDOW window_defn (COMMA window_defn)* -> ^(KW_WINDOW window_defn+)
+;
+
+window_defn
+@init { gParent.msgs.push("window_defn"); }
+@after { gParent.msgs.pop(); }
+:
+ Identifier KW_AS window_specification -> ^(TOK_WINDOWDEF Identifier window_specification)
+;
+
+window_specification
+@init { gParent.msgs.push("window_specification"); }
+@after { gParent.msgs.pop(); }
+:
+ (Identifier | ( LPAREN Identifier? partitioningSpec? window_frame? RPAREN)) -> ^(TOK_WINDOWSPEC Identifier? partitioningSpec? window_frame?)
+;
+
+window_frame :
+ window_range_expression |
+ window_value_expression
+;
+
+window_range_expression
+@init { gParent.msgs.push("window_range_expression"); }
+@after { gParent.msgs.pop(); }
+:
+ KW_ROWS KW_UNBOUNDED KW_PRECEDING -> ^(TOK_WINDOWRANGE ^(KW_PRECEDING KW_UNBOUNDED) ^(KW_CURRENT)) |
+ KW_ROWS KW_BETWEEN s=rowsboundary KW_AND end=rowsboundary -> ^(TOK_WINDOWRANGE $s $end)
+;
+
+rowsboundary
+@init { gParent.msgs.push("rowsboundary"); }
+@after { gParent.msgs.pop(); }
+:
+ KW_UNBOUNDED (r=KW_PRECEDING|r=KW_FOLLOWING) -> ^($r KW_UNBOUNDED) |
+ KW_CURRENT KW_ROW -> ^(KW_CURRENT) |
+ Number (d=KW_PRECEDING | d=KW_FOLLOWING ) -> ^($d Number)
+;
+
+window_value_expression
+@init { gParent.msgs.push("window_value_expression"); }
+@after { gParent.msgs.pop(); }
+:
+ KW_RANGE KW_UNBOUNDED KW_PRECEDING -> ^(TOK_WINDOWVALUES ^(KW_PRECEDING KW_UNBOUNDED) ^(KW_CURRENT)) |
+ KW_RANGE KW_BETWEEN s=valuesboundary KW_AND end=valuesboundary -> ^(TOK_WINDOWVALUES $s $end)
+;
+
+valuesboundary
+@init { gParent.msgs.push("valuesboundary"); }
+@after { gParent.msgs.pop(); }
+:
+ KW_UNBOUNDED (r=KW_PRECEDING|r=KW_FOLLOWING) -> ^($r KW_UNBOUNDED) |
+ KW_CURRENT KW_ROW -> ^(KW_CURRENT) |
+ rowExp=expression rngExp=Number (d=KW_LESS | d=KW_MORE ) -> ^($d $rowExp $rngExp)
+;
+
+
+
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_AmbiguousWindowDefn.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_AmbiguousWindowDefn.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_AmbiguousWindowDefn.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_AmbiguousWindowDefn.q Sat Mar 9 06:07:38 2013
@@ -16,9 +16,9 @@ LOAD DATA LOCAL INPATH '../data/files/pa
-- testAmbiguousWindowDefn
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over (w1),
-sum(p_size) as s2 over (w2),
-sum(p_size) as s3 over (w3)
+sum(p_size) over (w1) as s1,
+sum(p_size) over (w2) as s2,
+sum(p_size) over (w3) as s3
from part
distribute by p_mfgr
sort by p_mfgr
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DistributeByOrderBy.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DistributeByOrderBy.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DistributeByOrderBy.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DistributeByOrderBy.q Sat Mar 9 06:07:38 2013
@@ -14,6 +14,6 @@ CREATE TABLE part(
-- testPartitonBySortBy
select p_mfgr, p_name, p_size,
-sum(p_retailprice) as s1 over (distribute by p_mfgr order by p_mfgr)
+sum(p_retailprice) over (distribute by p_mfgr order by p_mfgr) as s1
from part
-;
\ No newline at end of file
+;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DuplicateWindowAlias.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DuplicateWindowAlias.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DuplicateWindowAlias.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_DuplicateWindowAlias.q Sat Mar 9 06:07:38 2013
@@ -14,8 +14,8 @@ CREATE TABLE part(
-- testDuplicateWindowAlias
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over (w1),
-sum(p_size) as s2 over (w2)
+sum(p_size) over (w1) as s1,
+sum(p_size) over (w2) as s2
from part
window w1 as (partition by p_mfgr order by p_mfgr rows between 2 preceding and 2 following),
w2 as w1,
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleDistributeClause.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleDistributeClause.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleDistributeClause.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleDistributeClause.q Sat Mar 9 06:07:38 2013
@@ -15,7 +15,7 @@ CREATE TABLE part(
-- testIncompatibleDistributeClause
select p_mfgr,p_name, p_size,
rank() as r, dense_rank() as dr,
-sum(p_size) as s over (w1)
+sum(p_size) over (w1) as s
from part
distribute by p_mfgr
window w1 as (partition by p_name rows between 2 preceding and 2 following);
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleOrderInWindowDefs.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleOrderInWindowDefs.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleOrderInWindowDefs.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleOrderInWindowDefs.q Sat Mar 9 06:07:38 2013
@@ -14,8 +14,8 @@ CREATE TABLE part(
-- testIncompatibleOrderInWindowDefs
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over (w1),
-sum(p_size) as s2 over (w2)
+sum(p_size) over (w1) as s1,
+sum(p_size) over (w2) as s2
from part
distribute by p_mfgr
sort by p_mfgr
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatiblePartitionInWindowDefs.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatiblePartitionInWindowDefs.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatiblePartitionInWindowDefs.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatiblePartitionInWindowDefs.q Sat Mar 9 06:07:38 2013
@@ -14,8 +14,8 @@ CREATE TABLE part(
-- testIncompatiblePartitionInWindowDefs
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over (w1),
-sum(p_size) as s2 over (w2)
+sum(p_size) over (w1) as s1,
+sum(p_size) over (w2) as s2
from part
distribute by p_mfgr
sort by p_mfgr
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleSortClause.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleSortClause.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleSortClause.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_IncompatibleSortClause.q Sat Mar 9 06:07:38 2013
@@ -15,7 +15,7 @@ CREATE TABLE part(
-- testIncompatibleSortClause
select p_mfgr,p_name, p_size,
rank() as r, dense_rank() as dr,
-sum(p_size) as s over (w1)
+sum(p_size) over (w1) as s
from part
distribute by p_mfgr
window w1 as (partition by p_mfgr order by p_name rows between 2 preceding and 2 following);
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_InvalidValueBoundary.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_InvalidValueBoundary.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_InvalidValueBoundary.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_InvalidValueBoundary.q Sat Mar 9 06:07:38 2013
@@ -16,9 +16,9 @@ LOAD DATA LOCAL INPATH '../data/files/pa
-- testInvalidValueBoundary
select p_mfgr,p_name, p_size,
-sum(p_size) as s over (w1) ,
+sum(p_size) over (w1) as s ,
dense_rank() as dr
from part
distribute by p_mfgr
sort by p_name
-window w1 as (range between p_name 2 less and current row);
\ No newline at end of file
+window w1 as (range between p_name 2 less and current row);
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_PartitionBySortBy.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_PartitionBySortBy.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_PartitionBySortBy.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_negative_PartitionBySortBy.q Sat Mar 9 06:07:38 2013
@@ -14,6 +14,6 @@ CREATE TABLE part(
-- testPartitonBySortBy
select p_mfgr, p_name, p_size,
-sum(p_retailprice) as s1 over (partition by p_mfgr sort by p_mfgr)
+sum(p_retailprice) over (partition by p_mfgr sort by p_mfgr) as s1
from part
-;
\ No newline at end of file
+;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries.q Sat Mar 9 06:07:38 2013
@@ -12,6 +12,6 @@ CREATE TABLE part(
);
select p_mfgr, p_name, p_size,
- sum(p_retailprice) as s1 over (rows unbounded following)
+ sum(p_retailprice) over (rows unbounded following) as s1
from part distribute by p_mfgr sort by p_name;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries2.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries2.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries2.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientnegative/ptf_window_boundaries2.q Sat Mar 9 06:07:38 2013
@@ -12,6 +12,6 @@ CREATE TABLE part(
);
select p_mfgr, p_name, p_size,
- sum(p_retailprice) as s1 over (range unbounded following)
+ sum(p_retailprice) over (range unbounded following) as s1
from part distribute by p_mfgr sort by p_name;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag.q Sat Mar 9 06:07:38 2013
@@ -19,7 +19,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_retailprice, sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -30,7 +30,7 @@ order by p_name
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from part
distribute by p_mfgr
@@ -53,7 +53,7 @@ window w1 as (rows between 2 preceding a
-- 5. testLagInSumOverWindow
select p_mfgr,p_name, p_size,
-sum(p_size - lag(p_size,1)) as deltaSum over w1
+sum(p_size - lag(p_size,1)) over w1 as deltaSum
from part
distribute by p_mfgr
sort by p_mfgr
@@ -61,7 +61,7 @@ window w1 as (rows between 2 preceding a
-- 6. testRankInLead
select p_mfgr, p_name, p_size, r1,
-lead(r1,1,r1) as deltaRank over (distribute by p_mfgr sort by p_name)
+lead(r1,1,r1) over (distribute by p_mfgr sort by p_name) as deltaRank
from (
select p_mfgr, p_name, p_size,
rank() as r1
@@ -83,8 +83,8 @@ sort by p_name;
-- 8. testOverNoPartitionMultipleAggregate
select p_name, p_retailprice,
-lead(p_retailprice) as l1 over(),
-lag(p_retailprice) as l2 over()
+lead(p_retailprice) over() as l1 ,
+lag(p_retailprice) over() as l2
from part
order by p_name;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag_queries.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag_queries.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag_queries.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/leadlag_queries.q Sat Mar 9 06:07:38 2013
@@ -15,10 +15,10 @@ LOAD DATA LOCAL INPATH '../data/files/pa
-- 1. testLeadUDAF
select p_mfgr, p_retailprice,
-lead(p_retailprice) as l1 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1) as l2 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1,10) as l3 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1, p_retailprice) as l4 over (partition by p_mfgr order by p_name),
+lead(p_retailprice) over (partition by p_mfgr order by p_name) as l1,
+lead(p_retailprice,1) over (partition by p_mfgr order by p_name) as l2,
+lead(p_retailprice,1,10) over (partition by p_mfgr order by p_name) as l3,
+lead(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l4,
p_retailprice - lead(p_retailprice,1,p_retailprice)
from part;
@@ -30,10 +30,10 @@ from part;
-- 3.testLagUDAF
select p_mfgr, p_retailprice,
-lag(p_retailprice,1) as l1 over (partition by p_mfgr order by p_name),
-lag(p_retailprice) as l2 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1, p_retailprice) as l3 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1,10) as l4 over (partition by p_mfgr order by p_name),
+lag(p_retailprice,1) over (partition by p_mfgr order by p_name) as l1,
+lag(p_retailprice) over (partition by p_mfgr order by p_name) as l2,
+lag(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l3,
+lag(p_retailprice,1,10) over (partition by p_mfgr order by p_name) as l4,
p_retailprice - lag(p_retailprice,1,p_retailprice)
from part;
@@ -45,9 +45,9 @@ from part;
-- 5.testLeadLagUDAF
select p_mfgr, p_retailprice,
-lead(p_retailprice,1) as l1 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1, p_retailprice) as l2 over (partition by p_mfgr order by p_name),
+lead(p_retailprice,1) over (partition by p_mfgr order by p_name) as l1,
+lead(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l2,
p_retailprice - lead(p_retailprice,1,p_retailprice),
-lag(p_retailprice,1) as l3 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1, p_retailprice) as l4 over (partition by p_mfgr order by p_name)
-from part;
\ No newline at end of file
+lag(p_retailprice,1) over (partition by p_mfgr order by p_name) as l3,
+lag(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l4
+from part;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf.q Sat Mar 9 06:07:38 2013
@@ -19,7 +19,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name
@@ -44,7 +44,7 @@ order by p_name);
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name
@@ -92,7 +92,7 @@ order by p_name
-- 9. testNoopWithMap
select p_mfgr, p_name, p_size,
-rank() as r over (partition by p_mfgr order by p_name, p_size desc)
+rank() over (partition by p_mfgr order by p_name, p_size desc) as r
from noopwithmap(on part
partition by p_mfgr
order by p_name, p_size desc);
@@ -101,7 +101,7 @@ order by p_name, p_size desc);
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noopwithmap(on part
partition by p_mfgr
order by p_name);
@@ -110,7 +110,7 @@ from noopwithmap(on part
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name)
@@ -120,7 +120,7 @@ having rank() < 4;
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+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
@@ -132,7 +132,7 @@ sub1.cd, sub1.s1
from (select p_mfgr, p_name,
count(p_size) as cd,
p_retailprice,
-sum(p_retailprice) as s1 over w1
+sum(p_retailprice) over w1 as s1
from noop(on part
partition by p_mfgr
order by p_name)
@@ -144,7 +144,7 @@ select abc.p_mfgr, abc.p_name,
rank() as r,
dense_rank() as dr,
count(abc.p_name) as cd,
-abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and current row),
+abc.p_retailprice, sum(abc.p_retailprice) over (rows between unbounded preceding and current row) as s1,
abc.p_size, abc.p_size - lag(abc.p_size,1,abc.p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -168,7 +168,7 @@ from part
group by p_mfgr, p_brand;
select p_mfgr, p_brand, s,
-sum(s) as s1 over w1
+sum(s) over w1 as s1
from noop(on mfgr_price_view
partition by p_mfgr
order by p_mfgr)
@@ -200,16 +200,16 @@ order by p_name)
INSERT OVERWRITE TABLE part_4 select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s
distribute by p_mfgr
sort by p_name
INSERT OVERWRITE TABLE part_5 select p_mfgr,p_name, p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (range between p_size 5 less and current row),
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (range between p_size 5 less and current row) as s2,
rank() as r,
dense_rank() as dr,
cume_dist() as cud,
-first_value(p_size, true) as fv1 over w1
+first_value(p_size, true) over w1 as fv1
having p_size > 5
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -223,7 +223,7 @@ select * from part_5;
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr,p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr,p_name rows between unbounded preceding and current row) as s1
from noop(on
noopwithmap(on
noop(on
@@ -240,7 +240,7 @@ from noop(on
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on
noop(on
noop(on
@@ -255,7 +255,7 @@ from noop(on
-- 20. testMultiOperatorChainWithNoWindowing
select p_mfgr, p_name,
-rank() as r over (partition by p_mfgr order by p_name),
+rank() over (partition by p_mfgr order by p_name) as r,
dense_rank() as dr,
p_size, sum(p_size) as s1
from noop(on
@@ -273,7 +273,7 @@ from noop(on
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr,p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr,p_name rows between unbounded preceding and current row) as s1
from noopwithmap(on
noop(on
noop(on
@@ -291,8 +291,8 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (partition by p_mfgr,p_name order by p_mfgr,p_name rows between unbounded preceding and current row)
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (partition by p_mfgr,p_name order by p_mfgr,p_name rows between unbounded preceding and current row) as s2
from noop(on
noopwithmap(on
noop(on part
@@ -307,8 +307,8 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (partition by p_mfgr order by p_mfgr rows between unbounded preceding and current row)
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (partition by p_mfgr order by p_mfgr rows between unbounded preceding and current row) as s2
from noopwithmap(on
noop(on
noop(on part
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_rcfile.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_rcfile.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_rcfile.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_rcfile.q Sat Mar 9 06:07:38 2013
@@ -18,7 +18,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_rc
partition by p_mfgr
order by p_name);
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_seqfile.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_seqfile.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_seqfile.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_seqfile.q Sat Mar 9 06:07:38 2013
@@ -18,7 +18,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_seq
partition by p_mfgr
order by p_name);
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing.q Sat Mar 9 06:07:38 2013
@@ -19,7 +19,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s1
from part
distribute by p_mfgr
sort by p_name;
@@ -57,7 +57,7 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
count(p_size) as cd,
-p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from part
distribute by p_mfgr
@@ -69,7 +69,7 @@ from (select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
count(p_size) as cd,
-p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from part
distribute by p_mfgr
@@ -80,7 +80,7 @@ sort by p_name
select abc.p_mfgr, abc.p_name,
rank() as r,
dense_rank() as dr,
-abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and current row),
+abc.p_retailprice, sum(abc.p_retailprice) over (rows between unbounded preceding and current row) as s1,
abc.p_size, abc.p_size - lag(abc.p_size,1,abc.p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -99,7 +99,7 @@ sort by p_name, p_size desc;
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s1
from part
having p_size > 5
distribute by p_mfgr
@@ -109,7 +109,7 @@ sort by p_name;
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s1
from part
having rank() < 4
distribute by p_mfgr
@@ -117,9 +117,9 @@ sort by p_name;
-- 11. testFirstLast
select p_mfgr,p_name, p_size,
-sum(p_size) as s2 over (rows between current row and current row),
-first_value(p_size) as f over w1 ,
-last_value(p_size, false) as l over w1
+sum(p_size) over (rows between current row and current row) as s2,
+first_value(p_size) over w1 as f,
+last_value(p_size, false) over w1 as l
from part
distribute by p_mfgr
sort by p_mfgr
@@ -128,9 +128,9 @@ window w1 as (rows between 2 preceding a
-- 12. testFirstLastWithWhere
select p_mfgr,p_name, p_size,
rank() as r,
-sum(p_size) as s2 over (rows between current row and current row),
-first_value(p_size) as f over w1,
-last_value(p_size, false) as l over w1
+sum(p_size) over (rows between current row and current row) as s2,
+first_value(p_size) over w1 as f,
+last_value(p_size, false) over w1 as l
from part
where p_mfgr = 'Manufacturer#3'
distribute by p_mfgr
@@ -139,8 +139,8 @@ window w1 as (rows between 2 preceding a
-- 13. testSumWindow
select p_mfgr,p_name, p_size,
-sum(p_size) as s1 over w1,
-sum(p_size) as s2 over (rows between current row and current row)
+sum(p_size) over w1 as s1,
+sum(p_size) over (rows between current row and current row) as s2
from part
distribute by p_mfgr
sort by p_mfgr
@@ -165,7 +165,7 @@ avg(p_size) as avg,
stddev(p_size) as st,
first_value(p_size % 5) as fv,
last_value(p_size) as lv,
-first_value(p_size, true) as fvW1 over w1
+first_value(p_size, true) over w1 as fvW1
from part
having p_size > 5
distribute by p_mfgr
@@ -176,9 +176,9 @@ window w1 as (rows between 2 preceding a
select p_mfgr,p_name, p_size,
rank() as r, dense_rank() as dr,
cume_dist() as cud,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (range between p_size 5 less and current row),
-first_value(p_size, true) as fv1 over w1
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (range between p_size 5 less and current row) as s2,
+first_value(p_size, true) over w1 as fv1
from part
having p_size > 5
distribute by p_mfgr
@@ -189,7 +189,7 @@ window w1 as (rows between 2 preceding a
select p_mfgr,p_name, p_size,
count(*) as c,
count(p_size) as ca,
-first_value(p_size, true) as fvW1 over w1
+first_value(p_size, true) over w1 as fvW1
from part
having p_size > 5
distribute by p_mfgr
@@ -198,10 +198,10 @@ window w1 as (rows between 2 preceding a
-- 18. testUDAFs
select p_mfgr,p_name, p_size,
-sum(p_retailprice) as s over w1,
-min(p_retailprice) as mi over w1,
-max(p_retailprice) as ma over w1,
-avg(p_retailprice) as ag over w1
+sum(p_retailprice) over w1 as s,
+min(p_retailprice) over w1 as mi,
+max(p_retailprice) over w1 as ma,
+avg(p_retailprice) over w1 as ag
from part
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -209,10 +209,10 @@ window w1 as (rows between 2 preceding a
-- 19. testUDAFsWithGBY
select p_mfgr,p_name, p_size, p_retailprice,
-sum(p_retailprice) as s over w1,
+sum(p_retailprice) over w1 as s,
min(p_retailprice) as mi ,
max(p_retailprice) as ma ,
-avg(p_retailprice) as ag over w1
+avg(p_retailprice) over w1 as ag
from part
group by p_mfgr,p_name, p_size, p_retailprice
distribute by p_mfgr
@@ -221,12 +221,12 @@ window w1 as (rows between 2 preceding a
-- 20. testSTATs
select p_mfgr,p_name, p_size,
-stddev(p_retailprice) as sdev over w1,
-stddev_pop(p_retailprice) as sdev_pop over w1,
-collect_set(p_size) as uniq_size over w1,
-variance(p_retailprice) as var over w1,
-corr(p_size, p_retailprice) as cor over w1,
-covar_pop(p_size, p_retailprice) as covarp over w1
+stddev(p_retailprice) over w1 as sdev,
+stddev_pop(p_retailprice) over w1 as sdev_pop,
+collect_set(p_size) over w1 as uniq_size,
+variance(p_retailprice) over w1 as var,
+corr(p_size, p_retailprice) over w1 as cor,
+covar_pop(p_size, p_retailprice) over w1 as covarp
from part
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -234,8 +234,8 @@ window w1 as (rows between 2 preceding a
-- 21. testDISTs
select p_mfgr,p_name, p_size,
-histogram_numeric(p_retailprice, 5) as hist over w1,
-percentile(p_partkey, 0.5) as per over w1,
+histogram_numeric(p_retailprice, 5) over w1 as hist,
+percentile(p_partkey, 0.5) over w1 as per,
row_number() as rn
from part
distribute by p_mfgr
@@ -250,7 +250,7 @@ from part
group by p_mfgr, p_brand;
select p_mfgr, p_brand, s,
-sum(s) as s1 over w1
+sum(s) over w1 as s1
from mfgr_price_view
distribute by p_mfgr
sort by p_mfgr
@@ -259,7 +259,7 @@ window w1 as (rows between 2 preceding a
-- 23. testCreateViewWithWindowingQuery
create view IF NOT EXISTS mfgr_brand_price_view as
select p_mfgr, p_brand,
-sum(p_retailprice) as s over w1
+sum(p_retailprice) over w1 as s
from part
distribute by p_mfgr
sort by p_mfgr
@@ -269,7 +269,7 @@ select * from mfgr_brand_price_view;
-- 24. testLateralViews
select p_mfgr, p_name,
-lv_col, p_size, sum(p_size) as s over w1
+lv_col, p_size, sum(p_size) over w1 as s
from (select p_mfgr, p_name, p_size, array(1,2,3) arr from part) p
lateral view explode(arr) part_lv as lv_col
distribute by p_mfgr
@@ -309,16 +309,16 @@ INSERT OVERWRITE TABLE part_1
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s
distribute by p_mfgr
sort by p_name
INSERT OVERWRITE TABLE part_2
select p_mfgr,p_name, p_size,
rank() as r, dense_rank() as dr,
cume_dist() as cud,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (range between p_size 5 less and current row),
-first_value(p_size, true) as fv1 over w1
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (range between p_size 5 less and current row) as s2,
+first_value(p_size, true) over w1 as fv1
having p_size > 5
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -327,7 +327,7 @@ INSERT OVERWRITE TABLE part_3
select p_mfgr,p_name, p_size,
count(*) as c,
count(p_size) as ca,
-first_value(p_size, true) as fv over w1
+first_value(p_size, true) over w1 as fv
having p_size > 5
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -352,8 +352,8 @@ sort by p_name;
-- 27. testMultipleRangeWindows
select p_mfgr,p_name, p_size,
-sum(p_size) as s2 over (range between p_size 10 less and current row),
-sum(p_size) as s1 over (range between current row and p_size 10 more )
+sum(p_size) over (range between p_size 10 less and current row) as s2,
+sum(p_size) over (range between current row and p_size 10 more ) as s1
from part
distribute by p_mfgr
sort by p_mfgr, p_size
@@ -361,19 +361,19 @@ window w1 as (rows between 2 preceding a
-- 28. testPartOrderInUDAFInvoke
select p_mfgr, p_name, p_size,
-sum(p_size) as s over (partition by p_mfgr order by p_name rows between 2 preceding and 2 following)
+sum(p_size) over (partition by p_mfgr order by p_name rows between 2 preceding and 2 following) as s
from part;
-- 29. testPartOrderInWdwDef
select p_mfgr, p_name, p_size,
-sum(p_size) as s over w1
+sum(p_size) over w1 as s
from part
window w1 as (partition by p_mfgr order by p_name rows between 2 preceding and 2 following);
-- 30. testDefaultPartitioningSpecRules
select p_mfgr, p_name, p_size,
-sum(p_size) as s over w1,
- sum(p_size) as s2 over w2
+sum(p_size) over w1 as s,
+sum(p_size) over w2 as s2
from part
sort by p_name
window w1 as (partition by p_mfgr rows between 2 preceding and 2 following),
@@ -381,8 +381,8 @@ window w1 as (partition by p_mfgr rows b
-- 31. testWindowCrossReference
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over w1,
-sum(p_size) as s2 over w2
+sum(p_size) over w1 as s1,
+sum(p_size) over w2 as s2
from part
window w1 as (partition by p_mfgr order by p_mfgr rows between 2 preceding and 2 following),
w2 as w1;
@@ -390,8 +390,8 @@ window w1 as (partition by p_mfgr order
-- 32. testWindowInheritance
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over w1,
-sum(p_size) as s2 over w2
+sum(p_size) over w1 as s1,
+sum(p_size) over w2 as s2
from part
window w1 as (partition by p_mfgr order by p_mfgr rows between 2 preceding and 2 following),
w2 as (w1 rows between unbounded preceding and current row);
@@ -399,9 +399,9 @@ window w1 as (partition by p_mfgr order
-- 33. testWindowForwardReference
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over w1,
-sum(p_size) as s2 over w2,
-sum(p_size) as s3 over w3
+sum(p_size) over w1 as s1,
+sum(p_size) over w2 as s2,
+sum(p_size) over w3 as s3
from part
distribute by p_mfgr
sort by p_mfgr
@@ -412,9 +412,9 @@ window w1 as (rows between 2 preceding a
-- 34. testWindowDefinitionPropagation
select p_mfgr, p_name, p_size,
-sum(p_size) as s1 over w1,
-sum(p_size) as s2 over w2,
-sum(p_size) as s3 over (w3 rows between 2 preceding and 2 following)
+sum(p_size) over w1 as s1,
+sum(p_size) over w2 as s2,
+sum(p_size) over (w3 rows between 2 preceding and 2 following) as s3
from part
distribute by p_mfgr
sort by p_mfgr
@@ -424,7 +424,7 @@ window w1 as (rows between 2 preceding a
-- 35. testDistinctWithWindowing
select DISTINCT p_mfgr, p_name, p_size,
-sum(p_size) as s over w1
+sum(p_size) over w1 as s
from part
distribute by p_mfgr
sort by p_name
@@ -432,48 +432,48 @@ window w1 as (rows between 2 preceding a
-- 36. testRankWithPartitioning
select p_mfgr, p_name, p_size,
-rank() as r over (partition by p_mfgr order by p_name )
+rank() over (partition by p_mfgr order by p_name ) as r
from part;
-- 37. testPartitioningVariousForms
select p_mfgr, p_name, p_size,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_mfgr),
-min(p_retailprice) as s2 over (partition by p_mfgr),
-max(p_retailprice) as s3 over (distribute by p_mfgr sort by p_mfgr),
-avg(p_retailprice) as s4 over (distribute by p_mfgr),
-count(p_retailprice) as s5 over (cluster by p_mfgr )
+sum(p_retailprice) over (partition by p_mfgr order by p_mfgr) as s1,
+min(p_retailprice) over (partition by p_mfgr) as s2,
+max(p_retailprice) over (distribute by p_mfgr sort by p_mfgr) as s3,
+avg(p_retailprice) over (distribute by p_mfgr) as s4,
+count(p_retailprice) over (cluster by p_mfgr ) as s5
from part;
-- 38. testPartitioningVariousForms2
select p_mfgr, p_name, p_size,
-sum(p_retailprice) as s1 over (partition by p_mfgr, p_name order by p_mfgr, p_name rows between unbounded preceding and current row),
-min(p_retailprice) as s2 over (distribute by p_mfgr, p_name sort by p_mfgr, p_name rows between unbounded preceding and current row),
-max(p_retailprice) as s3 over (cluster by p_mfgr, p_name )
+sum(p_retailprice) over (partition by p_mfgr, p_name order by p_mfgr, p_name rows between unbounded preceding and current row) as s1,
+min(p_retailprice) over (distribute by p_mfgr, p_name sort by p_mfgr, p_name rows between unbounded preceding and current row) as s2,
+max(p_retailprice) over (cluster by p_mfgr, p_name ) as s3
from part;
-- 39. testUDFOnOrderCols
select p_mfgr, p_type, substr(p_type, 2) as short_ptype,
-rank() as r over (partition by p_mfgr order by substr(p_type, 2))
+rank() over (partition by p_mfgr order by substr(p_type, 2)) as r
from part;
-- 40. testNoBetweenForRows
select p_mfgr, p_name, p_size,
- sum(p_retailprice) as s1 over (rows unbounded preceding)
+ sum(p_retailprice) over (rows unbounded preceding) as s1
from part distribute by p_mfgr sort by p_name;
-- 41. testNoBetweenForRange
select p_mfgr, p_name, p_size,
- sum(p_retailprice) as s1 over (range unbounded preceding)
+ sum(p_retailprice) over (range unbounded preceding) as s1
from part distribute by p_mfgr sort by p_name;
-- 42. testUnboundedFollowingForRows
select p_mfgr, p_name, p_size,
- sum(p_retailprice) as s1 over (rows between current row and unbounded following)
+ sum(p_retailprice) over (rows between current row and unbounded following) as s1
from part distribute by p_mfgr sort by p_name;
-- 43. testUnboundedFollowingForRange
select p_mfgr, p_name, p_size,
- sum(p_retailprice) as s1 over (range between current row and unbounded following)
+ sum(p_retailprice) over (range between current row and unbounded following) as s1
from part distribute by p_mfgr sort by p_name;
-- 44. testOverNoPartitionSingleAggregate
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_columnPruning.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_columnPruning.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_columnPruning.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_columnPruning.q Sat Mar 9 06:07:38 2013
@@ -17,17 +17,17 @@ LOAD DATA LOCAL INPATH '../data/files/pa
-- 1. testQueryLevelPartitionColsNotInSelect
select p_size,
-sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s1
from part
distribute by p_mfgr sort by p_name ;
-- 2. testWindowPartitionColsNotInSelect
select p_size,
-sum(p_retailprice) as s1 over (distribute by p_mfgr sort by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (distribute by p_mfgr sort by p_name rows between unbounded preceding and current row) as s1
from part;
-- 3. testHavingColNotInSelect
select p_mfgr,
-sum(p_retailprice) as s1 over (distribute by p_mfgr sort by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (distribute by p_mfgr sort by p_name rows between unbounded preceding and current row) as s1
from part
having p_size > 5;
Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_expressions.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_expressions.q?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_expressions.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/windowing_expressions.q Sat Mar 9 06:07:38 2013
@@ -43,8 +43,8 @@ sort by p_retailprice;
select p_mfgr, p_retailprice, p_size,
rank() as r,
-sum(p_retailprice) as s2 over (rows between unbounded preceding and current row),
-sum(p_retailprice) - 5 as s1 over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s2,
+sum(p_retailprice) - 5 over (rows between unbounded preceding and current row) as s1
from part
distribute by p_mfgr
sort by p_retailprice;
@@ -52,4 +52,4 @@ sort by p_retailprice;
select s, si, f, si - lead(f, 3) over (partition by t order by bo desc) from over10k limit 100;
select s, i, i - lead(i, 3, 0) over (partition by si order by i) from over10k limit 100;
select s, si, d, si - lag(d, 3) over (partition by b order by si) from over10k limit 100;
-select s, lag(s, 3, 'fred') over (partition by f order by b) from over10k limit 100;
\ No newline at end of file
+select s, lag(s, 3, 'fred') over (partition by f order by b) from over10k limit 100;
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_DistributeByOrderBy.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_DistributeByOrderBy.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_DistributeByOrderBy.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_DistributeByOrderBy.q.out Sat Mar 9 06:07:38 2013
@@ -27,5 +27,6 @@ POSTHOOK: query: CREATE TABLE part(
)
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: default@part
-FAILED: ParseException line 5:52 mismatched input 'order' expecting ) near 'p_mfgr' in window_specification
+FAILED: ParseException line 5:46 missing ) at 'order' near 'by'
+line 5:55 missing EOF at 'p_mfgr' near 'by'
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_PartitionBySortBy.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_PartitionBySortBy.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_PartitionBySortBy.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_negative_PartitionBySortBy.q.out Sat Mar 9 06:07:38 2013
@@ -27,5 +27,6 @@ POSTHOOK: query: CREATE TABLE part(
)
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: default@part
-FAILED: ParseException line 5:51 mismatched input 'sort' expecting ) near 'p_mfgr' in window_specification
+FAILED: ParseException line 5:45 missing ) at 'sort' near 'by'
+line 5:53 missing EOF at 'p_mfgr' near 'by'
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries.q.out Sat Mar 9 06:07:38 2013
@@ -25,5 +25,5 @@ CREATE TABLE part(
)
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: default@part
-FAILED: ParseException line 4:50 mismatched input 'following' expecting KW_PRECEDING near 'unbounded' in window_range_expression
+FAILED: ParseException line 4:44 mismatched input 'following' expecting KW_PRECEDING near 'unbounded' in window_range_expression
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries2.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries2.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries2.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientnegative/ptf_window_boundaries2.q.out Sat Mar 9 06:07:38 2013
@@ -25,5 +25,5 @@ CREATE TABLE part(
)
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: default@part
-FAILED: ParseException line 4:51 mismatched input 'following' expecting KW_PRECEDING near 'unbounded' in window_value_expression
+FAILED: ParseException line 4:45 mismatched input 'following' expecting KW_PRECEDING near 'unbounded' in window_value_expression
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag.q.out Sat Mar 9 06:07:38 2013
@@ -39,7 +39,7 @@ PREHOOK: query: --1. testLagWithPTFWindo
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_retailprice, sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -52,7 +52,7 @@ POSTHOOK: query: --1. testLagWithPTFWind
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_retailprice, sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -91,7 +91,7 @@ PREHOOK: query: -- 2. testLagWithWindowi
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from part
distribute by p_mfgr
@@ -103,7 +103,7 @@ POSTHOOK: query: -- 2. testLagWithWindow
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current row),
+p_retailprice, sum(p_retailprice) over (rows between unbounded preceding and current row) as s1,
p_size, p_size - lag(p_size,1,p_size) as deltaSz
from part
distribute by p_mfgr
@@ -231,7 +231,7 @@ Manufacturer#5 almond aquamarine dodger
Manufacturer#5 almond azure blanched chiffon midnight 23 -8
PREHOOK: query: -- 5. testLagInSumOverWindow
select p_mfgr,p_name, p_size,
-sum(p_size - lag(p_size,1)) as deltaSum over w1
+sum(p_size - lag(p_size,1)) over w1 as deltaSum
from part
distribute by p_mfgr
sort by p_mfgr
@@ -241,7 +241,7 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 5. testLagInSumOverWindow
select p_mfgr,p_name, p_size,
-sum(p_size - lag(p_size,1)) as deltaSum over w1
+sum(p_size - lag(p_size,1)) over w1 as deltaSum
from part
distribute by p_mfgr
sort by p_mfgr
@@ -277,7 +277,7 @@ Manufacturer#5 almond aquamarine dodger
Manufacturer#5 almond azure blanched chiffon midnight 23 21
PREHOOK: query: -- 6. testRankInLead
select p_mfgr, p_name, p_size, r1,
-lead(r1,1,r1) as deltaRank over (distribute by p_mfgr sort by p_name)
+lead(r1,1,r1) over (distribute by p_mfgr sort by p_name) as deltaRank
from (
select p_mfgr, p_name, p_size,
rank() as r1
@@ -289,7 +289,7 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 6. testRankInLead
select p_mfgr, p_name, p_size, r1,
-lead(r1,1,r1) as deltaRank over (distribute by p_mfgr sort by p_name)
+lead(r1,1,r1) over (distribute by p_mfgr sort by p_name) as deltaRank
from (
select p_mfgr, p_name, p_size,
rank() as r1
@@ -381,8 +381,8 @@ Manufacturer#5 almond aquamarine dodger
Manufacturer#5 almond azure blanched chiffon midnight 5 5 23 0
PREHOOK: query: -- 8. testOverNoPartitionMultipleAggregate
select p_name, p_retailprice,
-lead(p_retailprice) as l1 over(),
-lag(p_retailprice) as l2 over()
+lead(p_retailprice) over() as l1 ,
+lag(p_retailprice) over() as l2
from part
order by p_name
PREHOOK: type: QUERY
@@ -390,8 +390,8 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 8. testOverNoPartitionMultipleAggregate
select p_name, p_retailprice,
-lead(p_retailprice) as l1 over(),
-lag(p_retailprice) as l2 over()
+lead(p_retailprice) over() as l1 ,
+lag(p_retailprice) over() as l2
from part
order by p_name
POSTHOOK: type: QUERY
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag_queries.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag_queries.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag_queries.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientpositive/leadlag_queries.q.out Sat Mar 9 06:07:38 2013
@@ -33,10 +33,10 @@ POSTHOOK: type: LOAD
POSTHOOK: Output: default@part
PREHOOK: query: -- 1. testLeadUDAF
select p_mfgr, p_retailprice,
-lead(p_retailprice) as l1 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1) as l2 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1,10) as l3 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1, p_retailprice) as l4 over (partition by p_mfgr order by p_name),
+lead(p_retailprice) over (partition by p_mfgr order by p_name) as l1,
+lead(p_retailprice,1) over (partition by p_mfgr order by p_name) as l2,
+lead(p_retailprice,1,10) over (partition by p_mfgr order by p_name) as l3,
+lead(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l4,
p_retailprice - lead(p_retailprice,1,p_retailprice)
from part
PREHOOK: type: QUERY
@@ -44,10 +44,10 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 1. testLeadUDAF
select p_mfgr, p_retailprice,
-lead(p_retailprice) as l1 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1) as l2 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1,10) as l3 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1, p_retailprice) as l4 over (partition by p_mfgr order by p_name),
+lead(p_retailprice) over (partition by p_mfgr order by p_name) as l1,
+lead(p_retailprice,1) over (partition by p_mfgr order by p_name) as l2,
+lead(p_retailprice,1,10) over (partition by p_mfgr order by p_name) as l3,
+lead(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l4,
p_retailprice - lead(p_retailprice,1,p_retailprice)
from part
POSTHOOK: type: QUERY
@@ -123,10 +123,10 @@ Manufacturer#5 almond aquamarine dodger
Manufacturer#5 almond azure blanched chiffon midnight 1464.48 NULL 0.0
PREHOOK: query: -- 3.testLagUDAF
select p_mfgr, p_retailprice,
-lag(p_retailprice,1) as l1 over (partition by p_mfgr order by p_name),
-lag(p_retailprice) as l2 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1, p_retailprice) as l3 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1,10) as l4 over (partition by p_mfgr order by p_name),
+lag(p_retailprice,1) over (partition by p_mfgr order by p_name) as l1,
+lag(p_retailprice) over (partition by p_mfgr order by p_name) as l2,
+lag(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l3,
+lag(p_retailprice,1,10) over (partition by p_mfgr order by p_name) as l4,
p_retailprice - lag(p_retailprice,1,p_retailprice)
from part
PREHOOK: type: QUERY
@@ -134,10 +134,10 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 3.testLagUDAF
select p_mfgr, p_retailprice,
-lag(p_retailprice,1) as l1 over (partition by p_mfgr order by p_name),
-lag(p_retailprice) as l2 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1, p_retailprice) as l3 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1,10) as l4 over (partition by p_mfgr order by p_name),
+lag(p_retailprice,1) over (partition by p_mfgr order by p_name) as l1,
+lag(p_retailprice) over (partition by p_mfgr order by p_name) as l2,
+lag(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l3,
+lag(p_retailprice,1,10) over (partition by p_mfgr order by p_name) as l4,
p_retailprice - lag(p_retailprice,1,p_retailprice)
from part
POSTHOOK: type: QUERY
@@ -213,22 +213,22 @@ Manufacturer#5 almond aquamarine dodger
Manufacturer#5 almond azure blanched chiffon midnight 1464.48 NULL 0.0
PREHOOK: query: -- 5.testLeadLagUDAF
select p_mfgr, p_retailprice,
-lead(p_retailprice,1) as l1 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1, p_retailprice) as l2 over (partition by p_mfgr order by p_name),
+lead(p_retailprice,1) over (partition by p_mfgr order by p_name) as l1,
+lead(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l2,
p_retailprice - lead(p_retailprice,1,p_retailprice),
-lag(p_retailprice,1) as l3 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1, p_retailprice) as l4 over (partition by p_mfgr order by p_name)
+lag(p_retailprice,1) over (partition by p_mfgr order by p_name) as l3,
+lag(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l4
from part
PREHOOK: type: QUERY
PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 5.testLeadLagUDAF
select p_mfgr, p_retailprice,
-lead(p_retailprice,1) as l1 over (partition by p_mfgr order by p_name),
-lead(p_retailprice,1, p_retailprice) as l2 over (partition by p_mfgr order by p_name),
+lead(p_retailprice,1) over (partition by p_mfgr order by p_name) as l1,
+lead(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l2,
p_retailprice - lead(p_retailprice,1,p_retailprice),
-lag(p_retailprice,1) as l3 over (partition by p_mfgr order by p_name),
-lag(p_retailprice,1, p_retailprice) as l4 over (partition by p_mfgr order by p_name)
+lag(p_retailprice,1) over (partition by p_mfgr order by p_name) as l3,
+lag(p_retailprice,1, p_retailprice) over (partition by p_mfgr order by p_name) as l4
from part
POSTHOOK: type: QUERY
POSTHOOK: Input: default@part
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf.q.out Sat Mar 9 06:07:38 2013
@@ -39,7 +39,7 @@ PREHOOK: query: --1. test1
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name
@@ -51,7 +51,7 @@ POSTHOOK: query: --1. test1
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name
@@ -181,7 +181,7 @@ PREHOOK: query: -- 4. testPTFAlias
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name
@@ -193,7 +193,7 @@ POSTHOOK: query: -- 4. testPTFAlias
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name
@@ -432,7 +432,7 @@ POSTHOOK: Input: default@part
195606 almond aquamarine sandy cyan gainsboro Manufacturer#2 Brand#25 STANDARD PLATED TIN 18 SM PKG 1701.6 ic de
PREHOOK: query: -- 9. testNoopWithMap
select p_mfgr, p_name, p_size,
-rank() as r over (partition by p_mfgr order by p_name, p_size desc)
+rank() over (partition by p_mfgr order by p_name, p_size desc) as r
from noopwithmap(on part
partition by p_mfgr
order by p_name, p_size desc)
@@ -441,7 +441,7 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 9. testNoopWithMap
select p_mfgr, p_name, p_size,
-rank() as r over (partition by p_mfgr order by p_name, p_size desc)
+rank() over (partition by p_mfgr order by p_name, p_size desc) as r
from noopwithmap(on part
partition by p_mfgr
order by p_name, p_size desc)
@@ -478,7 +478,7 @@ PREHOOK: query: -- 10. testNoopWithMapWi
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noopwithmap(on part
partition by p_mfgr
order by p_name)
@@ -489,7 +489,7 @@ POSTHOOK: query: -- 10. testNoopWithMapW
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noopwithmap(on part
partition by p_mfgr
order by p_name)
@@ -526,7 +526,7 @@ PREHOOK: query: -- 11. testHavingWithWin
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name)
@@ -538,7 +538,7 @@ POSTHOOK: query: -- 11. testHavingWithWi
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part
partition by p_mfgr
order by p_name)
@@ -565,7 +565,7 @@ PREHOOK: query: -- 12. testFunctionChain
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+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
@@ -577,7 +577,7 @@ POSTHOOK: query: -- 12. testFunctionChai
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+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
@@ -617,7 +617,7 @@ sub1.cd, sub1.s1
from (select p_mfgr, p_name,
count(p_size) as cd,
p_retailprice,
-sum(p_retailprice) as s1 over w1
+sum(p_retailprice) over w1 as s1
from noop(on part
partition by p_mfgr
order by p_name)
@@ -632,7 +632,7 @@ sub1.cd, sub1.s1
from (select p_mfgr, p_name,
count(p_size) as cd,
p_retailprice,
-sum(p_retailprice) as s1 over w1
+sum(p_retailprice) over w1 as s1
from noop(on part
partition by p_mfgr
order by p_name)
@@ -672,7 +672,7 @@ select abc.p_mfgr, abc.p_name,
rank() as r,
dense_rank() as dr,
count(abc.p_name) as cd,
-abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and current row),
+abc.p_retailprice, sum(abc.p_retailprice) over (rows between unbounded preceding and current row) as s1,
abc.p_size, abc.p_size - lag(abc.p_size,1,abc.p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -688,7 +688,7 @@ select abc.p_mfgr, abc.p_name,
rank() as r,
dense_rank() as dr,
count(abc.p_name) as cd,
-abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and current row),
+abc.p_retailprice, sum(abc.p_retailprice) over (rows between unbounded preceding and current row) as s1,
abc.p_size, abc.p_size - lag(abc.p_size,1,abc.p_size) as deltaSz
from noop(on part
partition by p_mfgr
@@ -786,7 +786,7 @@ POSTHOOK: type: CREATEVIEW
POSTHOOK: Output: default@mfgr_price_view
#### A masked pattern was here ####
PREHOOK: query: select p_mfgr, p_brand, s,
-sum(s) as s1 over w1
+sum(s) over w1 as s1
from noop(on mfgr_price_view
partition by p_mfgr
order by p_mfgr)
@@ -796,7 +796,7 @@ PREHOOK: Input: default@mfgr_price_view
PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: select p_mfgr, p_brand, s,
-sum(s) as s1 over w1
+sum(s) over w1 as s1
from noop(on mfgr_price_view
partition by p_mfgr
order by p_mfgr)
@@ -869,16 +869,16 @@ order by p_name)
INSERT OVERWRITE TABLE part_4 select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s
distribute by p_mfgr
sort by p_name
INSERT OVERWRITE TABLE part_5 select p_mfgr,p_name, p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (range between p_size 5 less and current row),
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (range between p_size 5 less and current row) as s2,
rank() as r,
dense_rank() as dr,
cume_dist() as cud,
-first_value(p_size, true) as fv1 over w1
+first_value(p_size, true) over w1 as fv1
having p_size > 5
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -893,16 +893,16 @@ order by p_name)
INSERT OVERWRITE TABLE part_4 select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s over (rows between unbounded preceding and current row)
+sum(p_retailprice) over (rows between unbounded preceding and current row) as s
distribute by p_mfgr
sort by p_name
INSERT OVERWRITE TABLE part_5 select p_mfgr,p_name, p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (range between p_size 5 less and current row),
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (range between p_size 5 less and current row) as s2,
rank() as r,
dense_rank() as dr,
cume_dist() as cud,
-first_value(p_size, true) as fv1 over w1
+first_value(p_size, true) over w1 as fv1
having p_size > 5
distribute by p_mfgr
sort by p_mfgr, p_name
@@ -1023,7 +1023,7 @@ PREHOOK: query: -- 18. testMulti2Operato
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr,p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr,p_name rows between unbounded preceding and current row) as s1
from noop(on
noopwithmap(on
noop(on
@@ -1042,7 +1042,7 @@ POSTHOOK: query: -- 18. testMulti2Operat
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr,p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr,p_name rows between unbounded preceding and current row) as s1
from noop(on
noopwithmap(on
noop(on
@@ -1102,7 +1102,7 @@ PREHOOK: query: -- 19. testMulti3Operato
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on
noop(on
noop(on
@@ -1121,7 +1121,7 @@ POSTHOOK: query: -- 19. testMulti3Operat
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on
noop(on
noop(on
@@ -1179,7 +1179,7 @@ Manufacturer#5 almond aquamarine dodger
Manufacturer#5 almond azure blanched chiffon midnight 5 5 23 108
PREHOOK: query: -- 20. testMultiOperatorChainWithNoWindowing
select p_mfgr, p_name,
-rank() as r over (partition by p_mfgr order by p_name),
+rank() over (partition by p_mfgr order by p_name) as r,
dense_rank() as dr,
p_size, sum(p_size) as s1
from noop(on
@@ -1196,7 +1196,7 @@ PREHOOK: Input: default@part
#### A masked pattern was here ####
POSTHOOK: query: -- 20. testMultiOperatorChainWithNoWindowing
select p_mfgr, p_name,
-rank() as r over (partition by p_mfgr order by p_name),
+rank() over (partition by p_mfgr order by p_name) as r,
dense_rank() as dr,
p_size, sum(p_size) as s1
from noop(on
@@ -1256,7 +1256,7 @@ PREHOOK: query: -- 21. testMultiOperator
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr,p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr,p_name rows between unbounded preceding and current row) as s1
from noopwithmap(on
noop(on
noop(on
@@ -1275,7 +1275,7 @@ POSTHOOK: query: -- 21. testMultiOperato
select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
-p_size, sum(p_size) as s1 over (partition by p_mfgr,p_name rows between unbounded preceding and current row)
+p_size, sum(p_size) over (partition by p_mfgr,p_name rows between unbounded preceding and current row) as s1
from noopwithmap(on
noop(on
noop(on
@@ -1336,8 +1336,8 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (partition by p_mfgr,p_name order by p_mfgr,p_name rows between unbounded preceding and current row)
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (partition by p_mfgr,p_name order by p_mfgr,p_name rows between unbounded preceding and current row) as s2
from noop(on
noopwithmap(on
noop(on part
@@ -1354,8 +1354,8 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (partition by p_mfgr,p_name order by p_mfgr,p_name rows between unbounded preceding and current row)
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (partition by p_mfgr,p_name order by p_mfgr,p_name rows between unbounded preceding and current row) as s2
from noop(on
noopwithmap(on
noop(on part
@@ -1413,8 +1413,8 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (partition by p_mfgr order by p_mfgr rows between unbounded preceding and current row)
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (partition by p_mfgr order by p_mfgr rows between unbounded preceding and current row) as s2
from noopwithmap(on
noop(on
noop(on part
@@ -1429,8 +1429,8 @@ select p_mfgr, p_name,
rank() as r,
dense_rank() as dr,
p_size,
-sum(p_size) as s1 over (rows between unbounded preceding and current row),
-sum(p_size) as s2 over (partition by p_mfgr order by p_mfgr rows between unbounded preceding and current row)
+sum(p_size) over (rows between unbounded preceding and current row) as s1,
+sum(p_size) over (partition by p_mfgr order by p_mfgr rows between unbounded preceding and current row) as s2
from noopwithmap(on
noop(on
noop(on part
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_rcfile.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_rcfile.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_rcfile.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_rcfile.q.out Sat Mar 9 06:07:38 2013
@@ -37,7 +37,7 @@ PREHOOK: query: -- testWindowingPTFWithP
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_rc
partition by p_mfgr
order by p_name)
@@ -48,7 +48,7 @@ POSTHOOK: query: -- testWindowingPTFWith
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_rc
partition by p_mfgr
order by p_name)
Modified: hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_seqfile.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_seqfile.q.out?rev=1454661&r1=1454660&r2=1454661&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_seqfile.q.out (original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_seqfile.q.out Sat Mar 9 06:07:38 2013
@@ -37,7 +37,7 @@ PREHOOK: query: -- testWindowingPTFWithP
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_seq
partition by p_mfgr
order by p_name)
@@ -48,7 +48,7 @@ POSTHOOK: query: -- testWindowingPTFWith
select p_mfgr, p_name, p_size,
rank() as r,
dense_rank() as dr,
-sum(p_retailprice) as s1 over (partition by p_mfgr order by p_name rows between unbounded preceding and current row)
+sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_seq
partition by p_mfgr
order by p_name)