hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
Subject svn commit: r1446936 - in /hive/branches/ptf-windowing/ql/src: java/org/apache/hadoop/hive/ql/exec/ java/org/apache/hadoop/hive/ql/parse/ java/org/apache/hadoop/hive/ql/udf/generic/ test/queries/clientpositive/ test/results/clientpositive/
Date Sat, 16 Feb 2013 20:36:41 GMT
Author: hashutosh
Date: Sat Feb 16 20:36:40 2013
New Revision: 1446936

URL: http://svn.apache.org/r1446936
Log:
HIVE-4030 : Name windowing function in consistence with sql standard (Ashutosh Chauhan)

Modified:
    hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java
    hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFTranslator.java
    hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCumeDist.java
    hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFDenseRank.java
    hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFPercentRank.java
    hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRowNumber.java
    hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_general_queries.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/results/clientpositive/ptf_general_queries.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

Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java
(original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java
Sat Feb 16 20:36:40 2013
@@ -210,8 +210,8 @@ import org.apache.hadoop.hive.ql.udf.gen
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFStruct;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFTimestamp;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFToBinary;
-import org.apache.hadoop.hive.ql.udf.generic.GenericUDFToUnixTimeStamp;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFToDecimal;
+import org.apache.hadoop.hive.ql.udf.generic.GenericUDFToUnixTimeStamp;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFToUtcTimestamp;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFTranslate;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDFUnion;
@@ -520,18 +520,18 @@ public final class FunctionRegistry {
     registerGenericUDF(true, LAG_FUNC_NAME, GenericUDFLag.class);
 
     registerHiveUDAFsAsWindowFunctions();
-    registerWindowFunction("rownumber", new GenericUDAFRowNumber());
+    registerWindowFunction("row_number", new GenericUDAFRowNumber());
     registerWindowFunction("rank", new GenericUDAFRank());
-    registerWindowFunction("denserank", new GenericUDAFDenseRank());
-    registerWindowFunction("percentrank", new GenericUDAFPercentRank());
-    registerWindowFunction("cumedist", new GenericUDAFCumeDist());
+    registerWindowFunction("dense_rank", new GenericUDAFDenseRank());
+    registerWindowFunction("percent_rank", new GenericUDAFPercentRank());
+    registerWindowFunction("cume_dist", new GenericUDAFCumeDist());
     registerWindowFunction("ntile", new GenericUDAFNTile());
     registerWindowFunction("first_value", new GenericUDAFFirstValue());
     registerWindowFunction("last_value", new GenericUDAFLastValue());
 
     RANKING_FUNCTIONS.add("rank");
-    RANKING_FUNCTIONS.add("denserank");
-    RANKING_FUNCTIONS.add("percentrank");
+    RANKING_FUNCTIONS.add("dense_rank");
+    RANKING_FUNCTIONS.add("percent_rank");
 
     NAVIGATION_FUNCTIONS.add(LEAD_FUNC_NAME);
     NAVIGATION_FUNCTIONS.add(LAG_FUNC_NAME);
@@ -1093,36 +1093,36 @@ public final class FunctionRegistry {
     }
     if (udfMethods.size() > 1) {
 
-      // if the only difference is numeric types, pick the method 
+      // if the only difference is numeric types, pick the method
       // with the smallest overall numeric type.
       int lowestNumericType = Integer.MAX_VALUE;
       boolean multiple = true;
       Method candidate = null;
       List<TypeInfo> referenceArguments = null;
-      
+
       for (Method m: udfMethods) {
         int maxNumericType = 0;
-        
+
         List<TypeInfo> argumentsAccepted = TypeInfoUtils.getParameterTypeInfos(m, argumentsPassed.size());
-        
+
         if (referenceArguments == null) {
-          // keep the arguments for reference - we want all the non-numeric 
+          // keep the arguments for reference - we want all the non-numeric
           // arguments to be the same
           referenceArguments = argumentsAccepted;
         }
-        
+
         Iterator<TypeInfo> referenceIterator = referenceArguments.iterator();
-        
+
         for (TypeInfo accepted: argumentsAccepted) {
           TypeInfo reference = referenceIterator.next();
-          
+
           if (numericTypes.containsKey(accepted)) {
             // We're looking for the udf with the smallest maximum numeric type.
             int typeValue = numericTypes.get(accepted);
             maxNumericType = typeValue > maxNumericType ? typeValue : maxNumericType;
           } else if (!accepted.equals(reference)) {
             // There are non-numeric arguments that don't match from one UDF to
-            // another. We give up at this point. 
+            // another. We give up at this point.
             throw new AmbiguousMethodException(udfClass, argumentsPassed, mlist);
           }
         }

Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFTranslator.java
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFTranslator.java?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFTranslator.java
(original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFTranslator.java
Sat Feb 16 20:36:40 2013
@@ -626,9 +626,9 @@ public class PTFTranslator
   static
   {
     RANKING_FUNCS.add("rank");
-    RANKING_FUNCS.add("denserank");
-    RANKING_FUNCS.add("percentrank");
-    RANKING_FUNCS.add("cumedist");
+    RANKING_FUNCS.add("dense_rank");
+    RANKING_FUNCS.add("percent_rank");
+    RANKING_FUNCS.add("cume_dist");
   };
 
   private static void setupRankingArgs(PTFDesc ptfDesc, TableFuncDef windowTableFnDef,

Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCumeDist.java
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCumeDist.java?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCumeDist.java
(original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCumeDist.java
Sat Feb 16 20:36:40 2013
@@ -16,7 +16,7 @@ import org.apache.hadoop.io.IntWritable;
 @WindowFunctionDescription
 (
 		description = @Description(
-								name = "cumedist",
+								name = "cume_dist",
 								value = "_FUNC_(x) - The CUME_DIST function (defined as the inverse of percentile
in some " +
 									"statistical books) computes the position of a specified value relative to a set
of values. " +
 									"To compute the CUME_DIST of a value x in a set S of size N, you use the formula:
" +

Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFDenseRank.java
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFDenseRank.java?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFDenseRank.java
(original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFDenseRank.java
Sat Feb 16 20:36:40 2013
@@ -8,7 +8,7 @@ import org.apache.hadoop.hive.ql.exec.Wi
 @WindowFunctionDescription
 (
 		description = @Description(
-								name = "denserank",
+								name = "dense_rank",
 								value = "_FUNC_(x) The difference between RANK and DENSE_RANK is that DENSE_RANK
leaves no " +
 										"gaps in ranking sequence when there are ties. That is, if you were " +
 										"ranking a competition using DENSE_RANK and had three people tie for " +

Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFPercentRank.java
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFPercentRank.java?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFPercentRank.java
(original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFPercentRank.java
Sat Feb 16 20:36:40 2013
@@ -16,7 +16,7 @@ import org.apache.hadoop.io.IntWritable;
 @WindowFunctionDescription
 (
 		description = @Description(
-								name = "percentrank",
+								name = "percent_rank",
 								value = "_FUNC_(x) PERCENT_RANK is similar to CUME_DIST, but it uses rank values
rather " +
 									"than row counts in its numerator. PERCENT_RANK of a row is calculated as: " +
 									"(rank of row in its partition - 1) / (number of rows in the partition - 1)"

Modified: hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRowNumber.java
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRowNumber.java?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRowNumber.java
(original)
+++ hive/branches/ptf-windowing/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRowNumber.java
Sat Feb 16 20:36:40 2013
@@ -19,7 +19,7 @@ import org.apache.hadoop.io.IntWritable;
 @WindowFunctionDescription
 (
 		description = @Description(
-								name = "rowNumber",
+								name = "row_number",
 								value = "_FUNC_() - The ROW_NUMBER function assigns a unique number (sequentially,
starting from 1, as defined by ORDER BY) to each row within the partition."
 								),
 		supportsWindow = false,
@@ -74,7 +74,7 @@ public class GenericUDAFRowNumber extend
 			super.init(m, parameters);
 			if (m != Mode.COMPLETE)
 			{
-				throw new HiveException("Only COMPLETE mode supported for RowNumber function");
+				throw new HiveException("Only COMPLETE mode supported for row_number function");
 			}
 
 			return ObjectInspectorFactory.getStandardListObjectInspector(

Modified: hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_general_queries.q
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_general_queries.q?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_general_queries.q (original)
+++ hive/branches/ptf-windowing/ql/src/test/queries/clientpositive/ptf_general_queries.q Sat
Feb 16 20:36:40 2013
@@ -31,7 +31,7 @@ LOAD DATA LOCAL INPATH '../data/files/fl
 --1. test1
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part 
   distribute by p_mfgr
@@ -41,7 +41,7 @@ from noop(part 
 -- 2. test1NoPTF
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from part
 distribute by p_mfgr
@@ -50,7 +50,7 @@ sort by p_name;
 --3. testLeadLag
 select p_mfgr, p_name,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current
row),
 p_size, p_size - lag(p_size,1) as deltaSz
 from noop(part
@@ -61,7 +61,7 @@ sort by p_name 
 -- 4. testLeadLagNoPTF
 select p_mfgr, p_name,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current
row),
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
@@ -91,7 +91,7 @@ sort by j.p_name);    
 -- 8. testGroupByWithSWQ
 select p_mfgr, p_name, p_size, min(p_retailprice),
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -101,7 +101,7 @@ sort by p_name ;
 -- 9. testGroupByHavingWithSWQ
 select p_mfgr, p_name, p_size, min(p_retailprice),
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -118,7 +118,7 @@ sort by p_name);
 -- 11. testAlias
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part 
   distribute by p_mfgr
@@ -128,7 +128,7 @@ from noop(part 
 -- 12. testSWQAndPTFAndWhere
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, p_size - lag(p_size,1) as deltaSz 
 from noop(part 
           distribute by p_mfgr 
@@ -141,7 +141,7 @@ sort by p_name;
 -- 13. testSWQAndPTFAndGBy
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, p_size - lag(p_size,1) as deltaSz 
 from noop(part 
           distribute by p_mfgr 
@@ -154,7 +154,7 @@ sort by p_name;
 -- 14. testCountNoWindowing
 select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 count(p_size) as cd 
 from noop(part 
 distribute by p_mfgr 
@@ -163,7 +163,7 @@ sort by p_name);
 -- 15. testCountWithWindowing
 select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, p_size - lag(p_size,1) as deltaSz 
@@ -176,7 +176,7 @@ sort by p_name);
 select sub1.r, sub1.dr, sub1.cd, sub1.s1, sub1.deltaSz 
 from (select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, p_size - lag(p_size,1) as deltaSz 
@@ -202,7 +202,7 @@ sort by p_name 
 -- 19. testJoinWithWindowing
 select abc.p_mfgr, abc.p_name, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and
current row), 
 abc.p_size, abc.p_size - lag(abc.p_size,1) as deltaSz 
 from noop(part 
@@ -227,7 +227,7 @@ sort by p_name, p_size desc);
 -- 22. testNoopWithMapWithWindowing 
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noopwithmap(part 
   distribute by p_mfgr
@@ -236,7 +236,7 @@ from noopwithmap(part 
 -- 23. testHavingWithWindowingNoGBY
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from part 
 having p_size > 5 
@@ -246,7 +246,7 @@ sort by p_name; 
 -- 24. testHavingWithWindowingCondRankNoGBY
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from part 
 having r < 4 
@@ -256,7 +256,7 @@ sort by p_name;
 -- 25. testHavingWithWindowingPTFNoGBY
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part
 distribute by p_mfgr
@@ -304,7 +304,7 @@ window w1 as (rows between 2 preceding a
 
 -- 30. testNoSortClause
 select  p_mfgr,p_name, p_size, 
-rank() as r, denserank() as dr 
+rank() as r, dense_rank() as dr 
 from part 
 distribute by p_mfgr 
 window w1 as (rows between 2 preceding and 2 following);
@@ -312,9 +312,9 @@ window w1 as (rows between 2 preceding a
 -- 31. testExpressions
 select  p_mfgr,p_name, p_size,  
 rank() as r,  
-denserank() as dr, 
-cumedist() as cud, 
-percentrank() as pr, 
+dense_rank() as dr, 
+cume_dist() as cud, 
+percent_rank() as pr, 
 ntile(3) as nt, 
 count(p_size) as ca, 
 avg(p_size) as avg, 
@@ -330,8 +330,8 @@ window w1 as (rows between 2 preceding a
 
 -- 32. testMultipleWindows
 select  p_mfgr,p_name, p_size,  
-  rank() as r, denserank() as dr, 
-cumedist() as cud, 
+  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 
@@ -344,7 +344,7 @@ window w1 as (rows between 2 preceding a
 -- 33. testFunctionChain
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(noopwithmap(noop(part 
 distribute by p_mfgr 
@@ -378,7 +378,7 @@ window w1 as (rows between 2 preceding a
 -- 36. testJoinWithWindowingWithCount
 select abc.p_mfgr, abc.p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, abc.p_size - lag(abc.p_size,1) as deltaSz 
@@ -437,7 +437,7 @@ window w1 as (rows between 2 preceding a
 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,
-rownumber() as rn
+row_number() as rn
 from part
 distribute by p_mfgr
 sort by p_mfgr, p_name
@@ -536,14 +536,14 @@ from part 
 INSERT OVERWRITE TABLE part_1 
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s over (rows between unbounded preceding and current row) 
 distribute by p_mfgr 
 sort by p_name  
 INSERT OVERWRITE TABLE part_2 
 select  p_mfgr,p_name, p_size,  
-rank() as r, denserank() as dr, 
-cumedist() as cud, 
+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 
@@ -570,7 +570,7 @@ select * from part_3;
 -- 50. testGroupByHavingWithSWQAndAlias
 select p_mfgr, p_name, p_size, min(p_retailprice) as mi,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -612,7 +612,7 @@ distribute by p_mfgr 
 sort by p_name) 
 INSERT OVERWRITE TABLE part_4 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s over (rows between unbounded preceding and current row) 
 distribute by p_mfgr 
 sort by p_name  
@@ -620,8 +620,8 @@ INSERT OVERWRITE TABLE part_5 select  p_
 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), 
 rank() as r, 
-denserank() as dr, 
-cumedist() as cud, 
+dense_rank() as dr, 
+cume_dist() as cud, 
 first_value(p_size, true) as fv1 over w1 
 having p_size > 5 
 distribute by p_mfgr 
@@ -706,7 +706,7 @@ window w1 as (rows between 2 preceding a
 -- 61. testMulti2OperatorsFunctionChainWithMap
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row) 
 from noop(
         noopwithmap(
@@ -723,7 +723,7 @@ from noop(
 -- 62. testMulti3OperatorsFunctionChain
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row) 
 from noop(
         noop(
@@ -740,7 +740,7 @@ from noop(
 -- 63. testMultiOperatorChainWithNoWindowing
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 
 from noop(
         noop(
@@ -756,7 +756,7 @@ from noop(
 -- 64. testMultiOperatorChainEndsWithNoopMap
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row)  
 from noopwithmap(
         noop(
@@ -773,7 +773,7 @@ from noopwithmap(
 --65. testMultiOperatorChainWithDiffPartitionForWindow1
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+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 (distribute by p_mfgr,p_name sort by p_mfgr,p_name rows between unbounded
preceding and current row) 
@@ -789,7 +789,7 @@ from noop(
 --66. testMultiOperatorChainWithDiffPartitionForWindow2
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+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 (distribute by p_mfgr sort by p_mfgr rows between unbounded preceding
and current row) 

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=1446936&r1=1446935&r2=1446936&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 Feb 16
20:36:40 2013
@@ -17,7 +17,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
 -- testWindowingPTFWithPartRC
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(part_rc 
 distribute by p_mfgr 

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=1446936&r1=1446935&r2=1446936&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 Feb 16
20:36:40 2013
@@ -17,7 +17,7 @@ LOAD DATA LOCAL INPATH '../data/files/pa
 -- testWindowingPTFWithPartSeqFile
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(part_seq 
 distribute by p_mfgr 

Modified: hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_general_queries.q.out
URL: http://svn.apache.org/viewvc/hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_general_queries.q.out?rev=1446936&r1=1446935&r2=1446936&view=diff
==============================================================================
--- hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_general_queries.q.out
(original)
+++ hive/branches/ptf-windowing/ql/src/test/results/clientpositive/ptf_general_queries.q.out
Sat Feb 16 20:36:40 2013
@@ -69,7 +69,7 @@ POSTHOOK: Output: default@flights_tiny
 PREHOOK: query: --1. test1
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part 
   distribute by p_mfgr
@@ -81,7 +81,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: --1. test1
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part 
   distribute by p_mfgr
@@ -119,7 +119,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 2. test1NoPTF
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from part
 distribute by p_mfgr
@@ -130,7 +130,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 2. test1NoPTF
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from part
 distribute by p_mfgr
@@ -167,7 +167,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: --3. testLeadLag
 select p_mfgr, p_name,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current
row),
 p_size, p_size - lag(p_size,1) as deltaSz
 from noop(part
@@ -180,7 +180,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: --3. testLeadLag
 select p_mfgr, p_name,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current
row),
 p_size, p_size - lag(p_size,1) as deltaSz
 from noop(part
@@ -219,7 +219,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 4. testLeadLagNoPTF
 select p_mfgr, p_name,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current
row),
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
@@ -231,7 +231,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 4. testLeadLagNoPTF
 select p_mfgr, p_name,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_retailprice, sum(p_retailprice) as s1 over (rows between unbounded preceding and current
row),
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
@@ -403,7 +403,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 8. testGroupByWithSWQ
 select p_mfgr, p_name, p_size, min(p_retailprice),
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -415,7 +415,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 8. testGroupByWithSWQ
 select p_mfgr, p_name, p_size, min(p_retailprice),
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -452,7 +452,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 9. testGroupByHavingWithSWQ
 select p_mfgr, p_name, p_size, min(p_retailprice),
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -465,7 +465,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 9. testGroupByHavingWithSWQ
 select p_mfgr, p_name, p_size, min(p_retailprice),
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -545,7 +545,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 11. testAlias
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part 
   distribute by p_mfgr
@@ -557,7 +557,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 11. testAlias
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part 
   distribute by p_mfgr
@@ -595,7 +595,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 12. testSWQAndPTFAndWhere
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, p_size - lag(p_size,1) as deltaSz 
 from noop(part 
           distribute by p_mfgr 
@@ -610,7 +610,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 12. testSWQAndPTFAndWhere
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, p_size - lag(p_size,1) as deltaSz 
 from noop(part 
           distribute by p_mfgr 
@@ -651,7 +651,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 13. testSWQAndPTFAndGBy
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, p_size - lag(p_size,1) as deltaSz 
 from noop(part 
           distribute by p_mfgr 
@@ -666,7 +666,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 13. testSWQAndPTFAndGBy
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, p_size - lag(p_size,1) as deltaSz 
 from noop(part 
           distribute by p_mfgr 
@@ -706,7 +706,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 14. testCountNoWindowing
 select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 count(p_size) as cd 
 from noop(part 
 distribute by p_mfgr 
@@ -717,7 +717,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 14. testCountNoWindowing
 select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 count(p_size) as cd 
 from noop(part 
 distribute by p_mfgr 
@@ -754,7 +754,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 15. testCountWithWindowing
 select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, p_size - lag(p_size,1) as deltaSz 
@@ -767,7 +767,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 15. testCountWithWindowing
 select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, p_size - lag(p_size,1) as deltaSz 
@@ -807,7 +807,7 @@ PREHOOK: query: -- 16. testCountInSubQ
 select sub1.r, sub1.dr, sub1.cd, sub1.s1, sub1.deltaSz 
 from (select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, p_size - lag(p_size,1) as deltaSz 
@@ -822,7 +822,7 @@ POSTHOOK: query: -- 16. testCountInSubQ
 select sub1.r, sub1.dr, sub1.cd, sub1.s1, sub1.deltaSz 
 from (select p_mfgr, p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, p_size - lag(p_size,1) as deltaSz 
@@ -954,7 +954,7 @@ POSTHOOK: Input: default@part
 PREHOOK: query: -- 19. testJoinWithWindowing
 select abc.p_mfgr, abc.p_name, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and
current row), 
 abc.p_size, abc.p_size - lag(abc.p_size,1) as deltaSz 
 from noop(part 
@@ -969,7 +969,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 19. testJoinWithWindowing
 select abc.p_mfgr, abc.p_name, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 abc.p_retailprice, sum(abc.p_retailprice) as s1 over (rows between unbounded preceding and
current row), 
 abc.p_size, abc.p_size - lag(abc.p_size,1) as deltaSz 
 from noop(part 
@@ -1096,7 +1096,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 22. testNoopWithMapWithWindowing 
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noopwithmap(part 
   distribute by p_mfgr
@@ -1107,7 +1107,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 22. testNoopWithMapWithWindowing 
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noopwithmap(part 
   distribute by p_mfgr
@@ -1144,7 +1144,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 23. testHavingWithWindowingNoGBY
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from part 
 having p_size > 5 
@@ -1156,7 +1156,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 23. testHavingWithWindowingNoGBY
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from part 
 having p_size > 5 
@@ -1189,7 +1189,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 24. testHavingWithWindowingCondRankNoGBY
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from part 
 having r < 4 
@@ -1201,7 +1201,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 24. testHavingWithWindowingCondRankNoGBY
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from part 
 having r < 4 
@@ -1228,7 +1228,7 @@ Manufacturer#5	almond antique sky peru o
 PREHOOK: query: -- 25. testHavingWithWindowingPTFNoGBY
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part
 distribute by p_mfgr
@@ -1240,7 +1240,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 25. testHavingWithWindowingPTFNoGBY
 select p_mfgr, p_name, p_size,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row)
 from noop(part
 distribute by p_mfgr
@@ -1443,7 +1443,7 @@ Manufacturer#5	almond aquamarine dodger 
 Manufacturer#5	almond azure blanched chiffon midnight	23	71	23
 PREHOOK: query: -- 30. testNoSortClause
 select  p_mfgr,p_name, p_size, 
-rank() as r, denserank() as dr 
+rank() as r, dense_rank() as dr 
 from part 
 distribute by p_mfgr 
 window w1 as (rows between 2 preceding and 2 following)
@@ -1452,7 +1452,7 @@ PREHOOK: Input: default@part
 #### A masked pattern was here ####
 POSTHOOK: query: -- 30. testNoSortClause
 select  p_mfgr,p_name, p_size, 
-rank() as r, denserank() as dr 
+rank() as r, dense_rank() as dr 
 from part 
 distribute by p_mfgr 
 window w1 as (rows between 2 preceding and 2 following)
@@ -1488,9 +1488,9 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 31. testExpressions
 select  p_mfgr,p_name, p_size,  
 rank() as r,  
-denserank() as dr, 
-cumedist() as cud, 
-percentrank() as pr, 
+dense_rank() as dr, 
+cume_dist() as cud, 
+percent_rank() as pr, 
 ntile(3) as nt, 
 count(p_size) as ca, 
 avg(p_size) as avg, 
@@ -1509,9 +1509,9 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 31. testExpressions
 select  p_mfgr,p_name, p_size,  
 rank() as r,  
-denserank() as dr, 
-cumedist() as cud, 
-percentrank() as pr, 
+dense_rank() as dr, 
+cume_dist() as cud, 
+percent_rank() as pr, 
 ntile(3) as nt, 
 count(p_size) as ca, 
 avg(p_size) as avg, 
@@ -1550,8 +1550,8 @@ Manufacturer#5	almond aquamarine dodger 
 Manufacturer#5	almond azure blanched chiffon midnight	23	5	5	1.0	1.0	3	5	21.6	16.206171663906314
1	23	2
 PREHOOK: query: -- 32. testMultipleWindows
 select  p_mfgr,p_name, p_size,  
-  rank() as r, denserank() as dr, 
-cumedist() as cud, 
+  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 
@@ -1565,8 +1565,8 @@ PREHOOK: Input: default@part
 #### A masked pattern was here ####
 POSTHOOK: query: -- 32. testMultipleWindows
 select  p_mfgr,p_name, p_size,  
-  rank() as r, denserank() as dr, 
-cumedist() as cud, 
+  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 
@@ -1602,7 +1602,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 33. testFunctionChain
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(noopwithmap(noop(part 
 distribute by p_mfgr 
@@ -1614,7 +1614,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 33. testFunctionChain
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(noopwithmap(noop(part 
 distribute by p_mfgr 
@@ -1755,7 +1755,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 36. testJoinWithWindowingWithCount
 select abc.p_mfgr, abc.p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, abc.p_size - lag(abc.p_size,1) as deltaSz 
@@ -1771,7 +1771,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 36. testJoinWithWindowingWithCount
 select abc.p_mfgr, abc.p_name, 
 rank() as r, 
-denserank() as dr, 
+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_size, abc.p_size - lag(abc.p_size,1) as deltaSz 
@@ -2023,7 +2023,7 @@ PREHOOK: query: -- 41. 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,
-rownumber() as rn
+row_number() as rn
 from part
 distribute by p_mfgr
 sort by p_mfgr, p_name
@@ -2035,7 +2035,7 @@ POSTHOOK: query: -- 41. 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,
-rownumber() as rn
+row_number() as rn
 from part
 distribute by p_mfgr
 sort by p_mfgr, p_name
@@ -2482,14 +2482,14 @@ PREHOOK: query: from part 
 INSERT OVERWRITE TABLE part_1 
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s over (rows between unbounded preceding and current row) 
 distribute by p_mfgr 
 sort by p_name  
 INSERT OVERWRITE TABLE part_2 
 select  p_mfgr,p_name, p_size,  
-rank() as r, denserank() as dr, 
-cumedist() as cud, 
+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 
@@ -2515,14 +2515,14 @@ POSTHOOK: query: from part 
 INSERT OVERWRITE TABLE part_1 
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s over (rows between unbounded preceding and current row) 
 distribute by p_mfgr 
 sort by p_name  
 INSERT OVERWRITE TABLE part_2 
 select  p_mfgr,p_name, p_size,  
-rank() as r, denserank() as dr, 
-cumedist() as cud, 
+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 
@@ -2723,7 +2723,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 50. testGroupByHavingWithSWQAndAlias
 select p_mfgr, p_name, p_size, min(p_retailprice) as mi,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -2736,7 +2736,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 50. testGroupByHavingWithSWQAndAlias
 select p_mfgr, p_name, p_size, min(p_retailprice) as mi,
 rank() as r,
-denserank() as dr,
+dense_rank() as dr,
 p_size, p_size - lag(p_size,1) as deltaSz
 from part
 group by p_mfgr, p_name, p_size
@@ -2950,7 +2950,7 @@ distribute by p_mfgr 
 sort by p_name) 
 INSERT OVERWRITE TABLE part_4 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s over (rows between unbounded preceding and current row) 
 distribute by p_mfgr 
 sort by p_name  
@@ -2958,8 +2958,8 @@ INSERT OVERWRITE TABLE part_5 select  p_
 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), 
 rank() as r, 
-denserank() as dr, 
-cumedist() as cud, 
+dense_rank() as dr, 
+cume_dist() as cud, 
 first_value(p_size, true) as fv1 over w1 
 having p_size > 5 
 distribute by p_mfgr 
@@ -2974,7 +2974,7 @@ distribute by p_mfgr 
 sort by p_name) 
 INSERT OVERWRITE TABLE part_4 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s over (rows between unbounded preceding and current row) 
 distribute by p_mfgr 
 sort by p_name  
@@ -2982,8 +2982,8 @@ INSERT OVERWRITE TABLE part_5 select  p_
 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), 
 rank() as r, 
-denserank() as dr, 
-cumedist() as cud, 
+dense_rank() as dr, 
+cume_dist() as cud, 
 first_value(p_size, true) as fv1 over w1 
 having p_size > 5 
 distribute by p_mfgr 
@@ -3830,7 +3830,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 61. testMulti2OperatorsFunctionChainWithMap
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row) 
 from noop(
         noopwithmap(
@@ -3849,7 +3849,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 61. testMulti2OperatorsFunctionChainWithMap
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row) 
 from noop(
         noopwithmap(
@@ -3930,7 +3930,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 62. testMulti3OperatorsFunctionChain
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row) 
 from noop(
         noop(
@@ -3949,7 +3949,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 62. testMulti3OperatorsFunctionChain
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row) 
 from noop(
         noop(
@@ -4030,7 +4030,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 63. testMultiOperatorChainWithNoWindowing
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 
 from noop(
         noop(
@@ -4047,7 +4047,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 63. testMultiOperatorChainWithNoWindowing
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 
 from noop(
         noop(
@@ -4126,7 +4126,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: -- 64. testMultiOperatorChainEndsWithNoopMap
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row)  
 from noopwithmap(
         noop(
@@ -4145,7 +4145,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: -- 64. testMultiOperatorChainEndsWithNoopMap
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 p_size, sum(p_size) as s1 over (rows between unbounded preceding and current row)  
 from noopwithmap(
         noop(
@@ -4226,7 +4226,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: --65. testMultiOperatorChainWithDiffPartitionForWindow1
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+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 (distribute by p_mfgr,p_name sort by p_mfgr,p_name rows between unbounded
preceding and current row) 
@@ -4244,7 +4244,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: --65. testMultiOperatorChainWithDiffPartitionForWindow1
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+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 (distribute by p_mfgr,p_name sort by p_mfgr,p_name rows between unbounded
preceding and current row) 
@@ -4324,7 +4324,7 @@ Manufacturer#5	almond azure blanched chi
 PREHOOK: query: --66. testMultiOperatorChainWithDiffPartitionForWindow2
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+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 (distribute by p_mfgr sort by p_mfgr rows between unbounded preceding
and current row) 
@@ -4340,7 +4340,7 @@ PREHOOK: Input: default@part
 POSTHOOK: query: --66. testMultiOperatorChainWithDiffPartitionForWindow2
 select p_mfgr, p_name,  
 rank() as r, 
-denserank() as dr, 
+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 (distribute by p_mfgr sort by p_mfgr rows between unbounded preceding
and current row) 

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=1446936&r1=1446935&r2=1446936&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 Feb
16 20:36:40 2013
@@ -36,7 +36,7 @@ POSTHOOK: Output: default@part_rc
 PREHOOK: query: -- testWindowingPTFWithPartRC
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(part_rc 
 distribute by p_mfgr 
@@ -47,7 +47,7 @@ PREHOOK: Input: default@part_rc
 POSTHOOK: query: -- testWindowingPTFWithPartRC
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(part_rc 
 distribute by p_mfgr 

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=1446936&r1=1446935&r2=1446936&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 Feb
16 20:36:40 2013
@@ -36,7 +36,7 @@ POSTHOOK: Output: default@part_seq
 PREHOOK: query: -- testWindowingPTFWithPartSeqFile
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(part_seq 
 distribute by p_mfgr 
@@ -47,7 +47,7 @@ PREHOOK: Input: default@part_seq
 POSTHOOK: query: -- testWindowingPTFWithPartSeqFile
 select p_mfgr, p_name, p_size, 
 rank() as r, 
-denserank() as dr, 
+dense_rank() as dr, 
 sum(p_retailprice) as s1 over (rows between unbounded preceding and current row) 
 from noop(part_seq 
 distribute by p_mfgr 



Mime
View raw message