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 `" +
