svn commit: r1373533 - /hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java

[la...@apache.org]

Author: larsh
Date: Wed Aug 15 17:31:51 2012
New Revision: 1373533

URL: http://svn.apache.org/viewvc?rev=1373533&view=rev
Log:
HBASE-6577 RegionScannerImpl.nextRow() should seek to next row

Modified:
    hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java

Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java?rev=1373533&r1=1373532&r2=1373533&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java Wed Aug 15 17:31:51 2012
@@ -3480,7 +3480,7 @@ public class HRegion implements HeapSize
             // there're no left overs.
             // the reasons for calling this method are:
             // 1. reset the filters.
-            // 2. provide a hook to fast forward the row (used by subclasses)
+            // 2. fast forward the row
             nextRow(currentRow);
 
             // This row was totally filtered out, if this is NOT the last row,
@@ -3503,6 +3503,9 @@ public class HRegion implements HeapSize
     }
 
     protected void nextRow(byte [] currentRow) throws IOException {
+      KeyValue kv = KeyValue.createLastOnRow(currentRow);
+      this.storeHeap.requestSeek(kv, true, true);
+
       while (Bytes.equals(currentRow, peekRow())) {
         this.storeHeap.next(MOCKED_LIST);
       }