You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hbase.apache.org by la...@apache.org on 2013/10/17 22:11:09 UTC

svn commit: r1533240 - /hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java

Author: larsh
Date: Thu Oct 17 20:11:09 2013
New Revision: 1533240

URL: http://svn.apache.org/r1533240
Log:
HBASE-9747 PrefixFilter with OR condition gives wrong results (Aditya Kishore)

Modified:
    hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java

Modified: hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java?rev=1533240&r1=1533239&r2=1533240&view=diff
==============================================================================
--- hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java (original)
+++ hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java Thu Oct 17 20:11:09 2013
@@ -38,6 +38,7 @@ import java.util.ArrayList;
 public class PrefixFilter extends FilterBase {
   protected byte [] prefix = null;
   protected boolean passedPrefix = false;
+  protected boolean filterRow = true;
 
   public PrefixFilter(final byte [] prefix) {
     this.prefix = prefix;
@@ -60,7 +61,16 @@ public class PrefixFilter extends Filter
     if(cmp > 0) {
       passedPrefix = true;
     }
-    return cmp != 0;
+    filterRow = (cmp != 0);
+    return filterRow;
+  }
+
+  public boolean filterRow() {
+    return filterRow;
+  }
+
+  public void reset() {
+    filterRow = true;
   }
 
   public boolean filterAllRemaining() {