Index: hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 1373530) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 1373531) @@ -3603,7 +3603,7 @@ // 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, @@ -3616,16 +3616,15 @@ } } - private boolean filterRow() { - return filter != null - && filter.filterRow(); - } private boolean filterRowKey(byte[] row) { return filter != null && filter.filterRowKey(row, 0, row.length); } 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); }