svn commit: r700967 - in /incubator/pig/branches/types: CHANGES.txt src/org/apache/pig/builtin/TextLoader.java

[ol...@apache.org]

Author: olga
Date: Wed Oct  1 15:56:39 2008
New Revision: 700967

URL: http://svn.apache.org/viewvc?rev=700967&view=rev
Log:
PIG-470: TextLoader should return bytearrays

Modified:
    incubator/pig/branches/types/CHANGES.txt
    incubator/pig/branches/types/src/org/apache/pig/builtin/TextLoader.java

Modified: incubator/pig/branches/types/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/CHANGES.txt?rev=700967&r1=700966&r2=700967&view=diff
==============================================================================
--- incubator/pig/branches/types/CHANGES.txt (original)
+++ incubator/pig/branches/types/CHANGES.txt Wed Oct  1 15:56:39 2008
@@ -265,3 +265,5 @@
     PIG-437: as in alias names causing problems (sms via olgan)
 
     PIG-54: MIN/MAX don't deal with invalid data (pradeepk via olgan)
+
+    PIG-470: TextLoader should produce bytearrays (sms via olgan)

Modified: incubator/pig/branches/types/src/org/apache/pig/builtin/TextLoader.java
URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/src/org/apache/pig/builtin/TextLoader.java?rev=700967&r1=700966&r2=700967&view=diff
==============================================================================
--- incubator/pig/branches/types/src/org/apache/pig/builtin/TextLoader.java (original)
+++ incubator/pig/branches/types/src/org/apache/pig/builtin/TextLoader.java Wed Oct  1 15:56:39 2008
@@ -26,6 +26,7 @@
 
 import org.apache.pig.LoadFunc;
 import org.apache.pig.data.DataBag;
+import org.apache.pig.data.DataByteArray;
 import org.apache.pig.data.Tuple;
 import org.apache.pig.data.TupleFactory;
 import org.apache.pig.impl.io.BufferedPositionedInputStream;
@@ -56,7 +57,7 @@
             return null;
         String line;
         if ((line = in.readLine(utf8, (byte)'\n')) != null) {
-            return mTupleFactory.newTuple(new String(line));
+            return mTupleFactory.newTuple(new DataByteArray(line.getBytes()));
         }
         return null;
     }