Index: src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java (revision 1564378) +++ src/main/java/org/apache/hadoop/hbase/filter/PrefixFilter.java (working copy) @@ -25,6 +25,8 @@ import java.io.IOException; import java.util.ArrayList; +import org.apache.hadoop.hbase.KeyValue; +import org.apache.hadoop.hbase.filter.Filter.ReturnCode; import org.apache.hadoop.hbase.util.Bytes; import com.google.common.base.Preconditions; @@ -66,6 +68,12 @@ return filterRow; } + @Override + public ReturnCode filterKeyValue(KeyValue v) { + if (filterRowKey(v.getBuffer(), v.getRowOffset(), v.getRowLength())) return ReturnCode.SKIP; + return ReturnCode.INCLUDE; + } + public boolean filterRow() { return filterRow; }