You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by pi...@apache.org on 2008/07/23 15:20:05 UTC
svn commit: r679086 -
/incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java
Author: pisong
Date: Wed Jul 23 06:20:05 2008
New Revision: 679086
URL: http://svn.apache.org/viewvc?rev=679086&view=rev
Log:
Fixed type problem in TestStoreOld
Modified:
incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java
Modified: incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java
URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java?rev=679086&r1=679085&r2=679086&view=diff
==============================================================================
--- incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java (original)
+++ incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java Wed Jul 23 06:20:05 2008
@@ -60,7 +60,7 @@
pig.store("A", tmpFile1);
- pig.registerQuery("B = foreach (group A by $0) generate $0, SUM($1);");
+ pig.registerQuery("B = foreach (group A by $0) generate $0, SUM($1.$0);");
pig.store("B", tmpFile2);
pig.registerQuery("C = load " + tmpFile2 + ";");
Iterator<Tuple> iter = pig.openIterator("C");
@@ -78,9 +78,9 @@
public void testStoreWithMultipleMRJobs() throws Exception{
pig.registerQuery("A = load " + fileName + ";");
- pig.registerQuery("B = foreach (group A by $0) generate $0, SUM($1);");
- pig.registerQuery("C = foreach (group B by $0) generate $0, SUM($1);");
- pig.registerQuery("D = foreach (group C by $0) generate $0, SUM($1);");
+ pig.registerQuery("B = foreach (group A by $0) generate $0, SUM($1.$0);");
+ pig.registerQuery("C = foreach (group B by $0) generate $0, SUM($1.$0);");
+ pig.registerQuery("D = foreach (group C by $0) generate $0, SUM($1.$0);");
pig.store("D", tmpFile2);
pig.registerQuery("E = load " + tmpFile2 + ";");