TestFilter.java

import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;

import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.hbase.filter.FilterBase;
import org.apache.hadoop.hbase.util.Bytes;

/**
 * Test Filter<br/>
 * @author weic
 * @version 1.0 Feb 22, 2012
 * @see
 */
public class TestFilter extends FilterBase implements Filter{

    /**
     * Default constructor, filters nothing. Required though for RPC
     * deserialization.
     */
    public TestFilter(){
        super();
    }

    @Override
    public ReturnCode filterKeyValue(KeyValue v) {
        System.out.println("[filterKeyValue] family:" + Bytes.toString(v.getFamily()) + "|qualifier:" + Bytes.toString(v.getQualifier()) + "|value:" + Bytes.toStringBinary(v.getValue()));
        ReturnCode code = super.filterKeyValue(v);
        if(code == ReturnCode.INCLUDE){
            //once get a kv, jump to next row
            System.out.println("[filterKeyValue] ReturnCode is: " + ReturnCode.NEXT_ROW);
            return ReturnCode.NEXT_ROW;
        }else{
            System.out.println("[filterKeyValue] ReturnCode is: " + code.name());
            return code;
        }
    }

    @Override
    public boolean filterRow() {
        boolean filterRow = super.filterRow();
        System.out.println("[filterRow] filterOutRow:" + filterRow);
        return filterRow;
    }

    @Override
    public boolean filterRowKey(byte[] rowKey, int offset, int length) {
        System.out.println("[filterRowKey]" + Bytes.toStringBinary(rowKey));
        return super.filterRowKey(rowKey, offset, length);
    }

    @Override
    public void reset() {
        System.out.println("[reset]");
        super.reset();
    }

    @Override
    public void write(DataOutput out) throws IOException {
        // TODO Auto-generated method stub
    }

    @Override
    public void readFields(DataInput in) throws IOException {
        // TODO Auto-generated method stub
    }
}