Hbase 过滤器，

Hbase 过滤器，

 

编写程序代码如下，应用于order_items表，过滤出'price'列族，过滤出‘shop’列，过滤出值为’13‘的数据。

此过滤器应用于order_items表，famFilter为列族过滤器，此处过滤出'price'列族，

colFilter为列过滤器，此处过滤出‘shop’列，

valFilter为值过滤器，此处过滤出值为’13‘的数据。

import org.apache.hadoop.conf.Configuration;  
import org.apache.hadoop.hbase.HBaseConfiguration;  
import org.apache.hadoop.hbase.KeyValue;  
import org.apache.hadoop.hbase.client.HTable;  
import org.apache.hadoop.hbase.client.Result;  
import org.apache.hadoop.hbase.client.ResultScanner;  
import org.apache.hadoop.hbase.client.Scan;  
import org.apache.hadoop.hbase.filter.BinaryComparator;  
import org.apache.hadoop.hbase.filter.CompareFilter;  
import org.apache.hadoop.hbase.filter.Filter;  
import org.apache.hadoop.hbase.filter.QualifierFilter;  
import org.apache.hadoop.hbase.filter.FamilyFilter;  
import org.apache.hadoop.hbase.filter.FilterList;  
import org.apache.hadoop.hbase.filter.ValueFilter;  
import org.apache.hadoop.hbase.util.Bytes;  
import java.io.IOException;  
import java.util.ArrayList;  
import java.util.List;  
public class HBase {  
  public static void main(String[] args) throws IOException {  
    Configuration conf = HBaseConfiguration.create();  
    HTable table = new HTable(conf, "order_items");  
    List<Filter> filters = new ArrayList<Filter>();  
    Filter famFilter = new FamilyFilter(CompareFilter.CompareOp.EQUAL,  
    new BinaryComparator(Bytes.toBytes("price")));  
    filters.add(famFilter);  
    Filter colFilter = new QualifierFilter(CompareFilter.CompareOp.EQUAL,  
    new BinaryComparator(Bytes.toBytes("shop")));  
    filters.add(colFilter);  
    Filter valFilter = new ValueFilter(CompareFilter.CompareOp.EQUAL,  
    new BinaryComparator(Bytes.toBytes("13")));  
    filters.add(valFilter);  
    FilterList fl = new FilterList( FilterList.Operator.MUST_PASS_ALL, filters);  
    Scan scan = new Scan();  
    scan.setFilter(fl);  
    ResultScanner scanner = table.getScanner(scan);  
    System.out.println("Scanning table... ");  
    for (Result result : scanner) {  
    //System.out.println("getRow:"+Bytes.toString(result.getRow()));  
    for (KeyValue kv : result.raw()) {  
    //System.out.println("Family - "+Bytes.toString(kv.getFamily()));  
    //System.out.println("Qualifier - "+Bytes.toString(kv.getQualifier() ));  
    System.out.println("kv:"+kv +", Key: " + Bytes.toString(kv.getRow())  +  
    ", Value: " +Bytes.toString(kv.getValue()));  
    }  
    }  
    scanner.close();  
    System.out.println("Completed ");  
    }  
    }  

创建前缀过滤器（PrefixFilter），用于筛选出前缀为row的数据

import org.apache.hadoop.conf.Configuration;  
import org.apache.hadoop.hbase.HBaseConfiguration;  
import org.apache.hadoop.hbase.KeyValue;  
import org.apache.hadoop.hbase.client.HTable;  
import org.apache.hadoop.hbase.client.Result;  
import org.apache.hadoop.hbase.client.ResultScanner;  
import org.apache.hadoop.hbase.client.Scan;  
import org.apache.hadoop.hbase.filter.PrefixFilter;  
import org.apache.hadoop.hbase.filter.Filter;  
import org.apache.hadoop.hbase.util.Bytes;  
import java.io.IOException;  
public class Prffilter {  
  public static void main(String[] args) throws IOException {  
    Configuration conf = HBaseConfiguration.create();  
    HTable table = new HTable(conf, "order_items");  
      Filter filter = new PrefixFilter(Bytes.toBytes("row"));  
    Scan scan = new Scan();  
    scan.setFilter(filter);  
    ResultScanner scanner = table.getScanner(scan);  
    System.out.println("Scanning table... ");  
    for (Result result : scanner) {  
        //System.out.println("getRow:"+Bytes.toString(result.getRow()));  
        for (KeyValue kv : result.raw()) {  
            //System.out.println("Family - "+Bytes.toString(kv.getFamily()));  
            //System.out.println("Qualifier - "+Bytes.toString(kv.getQualifier() ));  
            System.out.println("kv:"+kv +", Key: " + Bytes.toString(kv.getRow())  +  
               ", Value: " +Bytes.toString(kv.getValue()));  
        }  
    }  
    scanner.close();  
    System.out.println("Completed ");  
  }  
}