You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ga...@apache.org on 2008/07/08 20:26:18 UTC
svn commit: r674908 -
/incubator/pig/branches/types/test/org/apache/pig/test/TestEvalPipeline.java
Author: gates
Date: Tue Jul 8 11:26:18 2008
New Revision: 674908
URL: http://svn.apache.org/viewvc?rev=674908&view=rev
Log:
PIG-287 Modified test to confirm bug is fixed. Thanks Santhosh.
Modified:
incubator/pig/branches/types/test/org/apache/pig/test/TestEvalPipeline.java
Modified: incubator/pig/branches/types/test/org/apache/pig/test/TestEvalPipeline.java
URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/test/org/apache/pig/test/TestEvalPipeline.java?rev=674908&r1=674907&r2=674908&view=diff
==============================================================================
--- incubator/pig/branches/types/test/org/apache/pig/test/TestEvalPipeline.java (original)
+++ incubator/pig/branches/types/test/org/apache/pig/test/TestEvalPipeline.java Tue Jul 8 11:26:18 2008
@@ -358,7 +358,7 @@
+ "C1 = filter A by $0 > -1;"
+ "C2 = distinct C1;"
+ "C3 = distinct A;"
- + "generate group," + Identity.class.getName() +"(*), COUNT(C2), SUM(C2.$1)," + TitleNGrams.class.getName() + "(C3), MAX(C3.$1);"
+ + "generate (int)group," + Identity.class.getName() +"(*), COUNT(C2), SUM(C2.$1)," + TitleNGrams.class.getName() + "(C3), MAX(C3.$1);"
+ "};";
pig.registerQuery(query);
@@ -367,6 +367,7 @@
int numIdentity = 0;
while(iter.hasNext()){
Tuple t = iter.next();
+ assertEquals((Integer)numIdentity, (Integer)t.get(0));
assertEquals((Long)5L, (Long)t.get(3));
assertEquals(LOOP_COUNT*2.0, (Double)t.get(4), 0.01);
assertEquals(8.0, (Double)t.get(6), 0.01);
@@ -376,5 +377,4 @@
assertEquals(LOOP_COUNT, numIdentity);
}
-
}