pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pradeep...@apache.org
Subject svn commit: r896716 - in /hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test: TestMultiQuery.java TestStreaming.java TestStreamingLocal.java
Date Wed, 06 Jan 2010 23:31:17 GMT
Author: pradeepkth
Date: Wed Jan  6 23:31:16 2010
New Revision: 896716

URL: http://svn.apache.org/viewvc?rev=896716&view=rev
Log:
PIG-1094: Fix unit tests corresponding to source changes so far - incremental patch to correct
issues due to removing 'split by file' from the language (rding via pradeepkth)

Modified:
    hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestMultiQuery.java
    hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreaming.java
    hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreamingLocal.java

Modified: hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestMultiQuery.java
URL: http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestMultiQuery.java?rev=896716&r1=896715&r2=896716&view=diff
==============================================================================
--- hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestMultiQuery.java (original)
+++ hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestMultiQuery.java Wed
Jan  6 23:31:16 2010
@@ -1391,7 +1391,7 @@
         try {
             myPig.setBatchOn();
 
-            myPig.registerQuery("A = load 'passwd' split by 'file';");
+            myPig.registerQuery("A = load 'passwd';");
             myPig.registerQuery("Split A into A1 if $2 > 5, A2 if $2 >= 5;");
             myPig.registerQuery("Split A1 into A3 if $0 > 'm', A4 if $0 >= 'm';");
             myPig.registerQuery("B = group A3 by $2;");
@@ -1425,7 +1425,7 @@
         try {
             myPig.setBatchOn();
 
-            myPig.registerQuery("A = load 'passwd' split by 'file';");
+            myPig.registerQuery("A = load 'passwd';");
             myPig.registerQuery("Split A into A1 if $2 > 5, A2 if $2 >= 5;");
             myPig.registerQuery("Split A1 into A3 if $0 > 'm', A4 if $0 >= 'm';");
             myPig.registerQuery("B = group A3 by $2;");

Modified: hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreaming.java
URL: http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreaming.java?rev=896716&r1=896715&r2=896716&view=diff
==============================================================================
--- hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreaming.java (original)
+++ hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreaming.java Wed
Jan  6 23:31:16 2010
@@ -730,7 +730,7 @@
             pigServer.registerQuery("IP = load '" 
                     + Util.generateURI(Util.encodeEscape(input.toString()),
                             pigServer.getPigContext()) + "' using " 
-                    + PigStorage.class.getName() + "(',') " + "split by 'file';");
+                    + PigStorage.class.getName() + "(',');");
             pigServer.registerQuery("FILTERED_DATA = filter IP by $1 > '3';");
             if(withTypes[i] == true) {
                 pigServer.registerQuery("OP = stream FILTERED_DATA through `" +

Modified: hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreamingLocal.java
URL: http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreamingLocal.java?rev=896716&r1=896715&r2=896716&view=diff
==============================================================================
--- hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreamingLocal.java
(original)
+++ hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestStreamingLocal.java
Wed Jan  6 23:31:16 2010
@@ -318,8 +318,7 @@
             pigServer.registerQuery("define CMD `"+ simpleEchoStreamingCommand + 
             "` input(stdin);");
             pigServer.registerQuery("IP = load 'file:" + Util.encodeEscape(input.toString())
+ "' using " + 
-                    PigStorage.class.getName() + "(',') " +
-            "split by 'file';");
+                    PigStorage.class.getName() + "(',');");
             pigServer.registerQuery("FILTERED_DATA = filter IP by $1 > '3';");
             if(withTypes[i] == true) {
                 pigServer.registerQuery("OP = stream FILTERED_DATA through `" +



Mime
View raw message