You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by pr...@apache.org on 2010/01/07 00:31:17 UTC
svn commit: r896716 - in
/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test:
TestMultiQuery.java TestStreaming.java TestStreamingLocal.java
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 `" +