hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject svn commit: r742147 - in /hadoop/hbase/branches/0.19: CHANGES.txt src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java
Date Sun, 08 Feb 2009 19:33:29 GMT
Author: apurtell
Date: Sun Feb  8 19:33:29 2009
New Revision: 742147

URL: http://svn.apache.org/viewvc?rev=742147&view=rev
Log:
HBASE-1190 TableInputFormatBase with row filters scan too far

Modified:
    hadoop/hbase/branches/0.19/CHANGES.txt
    hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java

Modified: hadoop/hbase/branches/0.19/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.19/CHANGES.txt?rev=742147&r1=742146&r2=742147&view=diff
==============================================================================
--- hadoop/hbase/branches/0.19/CHANGES.txt (original)
+++ hadoop/hbase/branches/0.19/CHANGES.txt Sun Feb  8 19:33:29 2009
@@ -7,6 +7,8 @@
    HBASE-1138  Make HLog block size configurable
    HBASE-1175  HBA administrative tools do not work when specifying region
                names (Jonathan Gray via Andrew Purtell)
+   HBASE-1190  TableInputFormatBase with row filters scan too far (Dave
+               Latham via Andrew Purtell)
 
   IMPROVEMENTS
    HBASE-845   HCM.isTableEnabled doesn't really tell if it is, or not

Modified: hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java?rev=742147&r1=742146&r2=742147&view=diff
==============================================================================
--- hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java
(original)
+++ hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java
Sun Feb  8 19:33:29 2009
@@ -32,6 +32,7 @@
 import org.apache.hadoop.hbase.filter.RowFilterInterface;
 import org.apache.hadoop.hbase.filter.RowFilterSet;
 import org.apache.hadoop.hbase.filter.StopRowFilter;
+import org.apache.hadoop.hbase.filter.WhileMatchRowFilter;
 import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
 import org.apache.hadoop.hbase.io.RowResult;
 import org.apache.hadoop.hbase.regionserver.HRegion;
@@ -104,7 +105,7 @@
         if (trrRowFilter != null) {
           final Set<RowFilterInterface> rowFiltersSet =
             new HashSet<RowFilterInterface>();
-          rowFiltersSet.add(new StopRowFilter(endRow));
+          rowFiltersSet.add(new WhileMatchRowFilter(new StopRowFilter(endRow)));
           rowFiltersSet.add(trrRowFilter);
           this.scanner = this.htable.getScanner(trrInputColumns, startRow,
             new RowFilterSet(RowFilterSet.Operator.MUST_PASS_ALL,



Mime
View raw message