Author: olga
Date: Mon Dec 10 16:27:15 2007
New Revision: 603105

URL: http://svn.apache.org/viewvc?rev=603105&view=rev
Log:
PIG-39: created more efficient version of read

Modified:
    incubator/pig/trunk/CHANGES.txt
    
incubator/pig/trunk/src/org/apache/pig/impl/io/BufferedPositionedInputStream.java

Modified: incubator/pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/CHANGES.txt?rev=603105&r1=603104&r2=603105&view=diff
==============================================================================
--- incubator/pig/trunk/CHANGES.txt (original)
+++ incubator/pig/trunk/CHANGES.txt Mon Dec 10 16:27:15 2007
@@ -53,3 +53,4 @@
 
        PIG-44: Added adaptive decision of the number of records to hold in 
memory 
        before spilling (utkarsh)
+    PIG-39: created more efficient version of read (spullara via olgan)

Modified: 
incubator/pig/trunk/src/org/apache/pig/impl/io/BufferedPositionedInputStream.java
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/src/org/apache/pig/impl/io/BufferedPositionedInputStream.java?rev=603105&r1=603104&r2=603105&view=diff
==============================================================================
--- 
incubator/pig/trunk/src/org/apache/pig/impl/io/BufferedPositionedInputStream.java
 (original)
+++ 
incubator/pig/trunk/src/org/apache/pig/impl/io/BufferedPositionedInputStream.java
 Mon Dec 10 16:27:15 2007
@@ -42,6 +42,13 @@
         pos++;
         return c;
        }
+
+    @Override
+    public int read(byte b[], int off, int len) throws IOException {
+        int read = in.read(b, off, len);
+        pos += read;
+        return read;
+    }
        
     @Override
        public long skip(long n) throws IOException {


Reply via email to