Author: pradeepkth
Date: Tue Feb 23 23:11:17 2010
New Revision: 915578
URL: http://svn.apache.org/viewvc?rev=915578&view=rev
Log:
minor fix to a test case to comply with new location of PigStreaming
Modified:
hadoop/pig/trunk/test/org/apache/pig/test/TestTypeCheckingValidator.java
Modified:
hadoop/pig/trunk/test/org/apache/pig/test/TestTypeCheckingValidator.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/trunk/test/org/apache/pig/test/TestTypeCheckingValidator.java?rev=915578&r1=915577&r2=915578&view=diff
==============================================================================
--- hadoop/pig/trunk/test/org/apache/pig/test/TestTypeCheckingValidator.java
(original)
+++ hadoop/pig/trunk/test/org/apache/pig/test/TestTypeCheckingValidator.java
Tue Feb 23 23:11:17 2010
@@ -5242,7 +5242,7 @@
LOCast cast = (LOCast)foreachPlan.getSuccessors(exOp).get(0);
-
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.impl.streaming.PigStreaming"));
+
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.builtin.PigStreaming"));
}
@@ -5274,7 +5274,7 @@
LOCast cast = (LOCast)foreachPlan.getSuccessors(exOp).get(0);
-
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.impl.streaming.PigStreaming"));
+
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.builtin.PigStreaming"));
foreachPlan = foreach.getForEachPlans().get(1);
@@ -5321,7 +5321,7 @@
exOp = foreachPlan.getRoots().get(0);
if(! (exOp instanceof LOProject)) exOp = foreachPlan.getRoots().get(1);
cast = (LOCast)foreachPlan.getSuccessors(exOp).get(0);
-
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.impl.streaming.PigStreaming"));
+
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.builtin.PigStreaming"));
}
@@ -5361,7 +5361,7 @@
exOp = foreachPlan.getRoots().get(0);
if(! (exOp instanceof LOProject)) exOp = foreachPlan.getRoots().get(1);
cast = (LOCast)foreachPlan.getSuccessors(exOp).get(0);
-
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.impl.streaming.PigStreaming"));
+
assertTrue(cast.getLoadFuncSpec().getClassName().startsWith("org.apache.pig.builtin.PigStreaming"));
}