hbase RowFilter如何根据rowkey查询以及实例实现代码 habase模糊查询【转】

RowFilter用于过滤row key
Operator Description
LESS 小于
LESS_OR_EQUAL 小于等于
[EQUAL 等于
NOT_EQUAL 不等于
GREATER_OR_EQUAL 大于等于
GREATER 大于
NO_OP 排除所有

 

Comparator Description
BinaryComparator 使用Bytes.compareTo()比较
BinaryPrefixComparator 和BinaryComparator差不多，从前面开始比较
NullComparator Does not compare against an actual value but whether a given one is null, or not  null.
BitComparator Performs a bitwise comparison, providing a BitwiseOp class with OR, and XORoperators.
RegexStringComparator 正则表达式
SubstringComparator 把数据当成字符串，用contains()来判断

 

  1. import java.io.IOException;
  3. import org.apache.hadoop.conf.Configuration;
  4. import org.apache.hadoop.hbase.HBaseConfiguration;
  5. import org.apache.hadoop.hbase.HColumnDescriptor;
  6. import org.apache.hadoop.hbase.HTableDescriptor;
  7. import org.apache.hadoop.hbase.client.HBaseAdmin;
  8. import org.apache.hadoop.hbase.client.HTable;
  9. import org.apache.hadoop.hbase.client.Put;
  10. import org.apache.hadoop.hbase.client.Result;
  11. import org.apache.hadoop.hbase.client.ResultScanner;
  12. import org.apache.hadoop.hbase.client.Scan;
  13. import org.apache.hadoop.hbase.filter.BinaryComparator;
  14. import org.apache.hadoop.hbase.filter.BinaryPrefixComparator;
  15. import org.apache.hadoop.hbase.filter.CompareFilter;
  16. import org.apache.hadoop.hbase.filter.Filter;
  17. import org.apache.hadoop.hbase.filter.RegexStringComparator;
  18. import org.apache.hadoop.hbase.filter.RowFilter;
  19. import org.apache.hadoop.hbase.filter.SubstringComparator;
  21. public class TestHbaseRowFilter {
  22.         String tableName = "test_row_filter";
  23.         Configuration config = HBaseConfiguration.create();
  25.         /**
  26.          * 部分代码来自hbase权威指南
  27.          * @throws IOException
  28.          */
  29.         public void testRowFilter() throws IOException {
  31.                 HTable table = new HTable(config, tableName);
  32.                 Scan scan = new Scan();
  34.                 System.out.println("小于等于row010的行");
  35.                 Filter filter1 = new RowFilter(CompareFilter.CompareOp.LESS_OR_EQUAL,
  36.                                 new BinaryComparator("row010".getBytes()));
  37.                 scan.setFilter(filter1);
  38.                 ResultScanner scanner1 = table.getScanner(scan);
  39.                 for (Result res : scanner1) {
  40.                         System.out.println(res);
  41.                 }
  42.                 scanner1.close();
  44.                 System.out.println("正则获取结尾为5的行");
  45.                 Filter filter2 = new RowFilter(CompareFilter.CompareOp.EQUAL,
  46.                                 new RegexStringComparator(".*5[        DISCUZ_CODE_0        ]quot;));
  47.                 scan.setFilter(filter2);
  48.                 ResultScanner scanner2 = table.getScanner(scan);
  49.                 for (Result res : scanner2) {
  50.                         System.out.println(res);
  51.                 }
  52.                 scanner2.close();
  54.                 System.out.println("包含有5的行");
  55.                 Filter filter3 = new RowFilter(CompareFilter.CompareOp.EQUAL,
  56.                                 new SubstringComparator("5"));
  57.                 scan.setFilter(filter3);
  58.                 ResultScanner scanner3 = table.getScanner(scan);
  59.                 for (Result res : scanner3) {
  60.                         System.out.println(res);
  61.                 }
  62.                 scanner3.close();
  64.                 System.out.println("开头是row01的");
  65.                 Filter filter4 = new RowFilter(CompareFilter.CompareOp.EQUAL,
  66.                                 new BinaryPrefixComparator("row01".getBytes()));
  67.                 scan.setFilter(filter4);
  68.                 ResultScanner scanner4 = table.getScanner(scan);
  69.                 for (Result res : scanner4) {
  70.                         System.out.println(res);
  71.                 }
  72.                 scanner3.close();
  73.         }
  75.         /**
  76.          * 初始化数据
  77.          */
  78.         public void init() {
  79.                 // 创建表和初始化数据
  80.                 try {
  81.                         HBaseAdmin admin = new HBaseAdmin(config);
  82.                         if (!admin.tableExists(tableName)) {
  83.                                 HTableDescriptor htd = new HTableDescriptor(tableName);
  84.                                 HColumnDescriptor hcd1 = new HColumnDescriptor("data");
  85.                                 htd.addFamily(hcd1);
  86.                                 HColumnDescriptor hcd2 = new HColumnDescriptor("url");
  87.                                 htd.addFamily(hcd2);
  89.                                 admin.createTable(htd);
  90.                         }
  92.                         HTable table = new HTable(config, tableName);
  94.                         table.setAutoFlush(false);
  95.                         int count = 50;
  96.                         for (int i = 1; i <= count; ++i) {
  97.                                 Put p = new Put(String.format("row%03d", i).getBytes());
  98.                                 p.add("data".getBytes(), String.format("col%01d", i % 10)
  99.                                                 .getBytes(), String.format("data%03d", i).getBytes());
  100.                                 p.add("url".getBytes(), String.format("col%01d", i % 10)
  101.                                                 .getBytes(), String.format("url%03d", i).getBytes());
  102.                                 table.put(p);
  103.                         }
  104.                         table.close();
  106.                 } catch (IOException e) {
  107.                         e.printStackTrace();
  108.                 }
  109.         }
  111.         /**
  112.          * @param args
  113.          * @throws IOException
  114.          */
  115.         public static void main(String[] args) throws IOException {
  116.                 TestHbaseRowFilter test = new TestHbaseRowFilter();
  117.                 test.init();
  118.                 test.testRowFilter();
  119.         }
  121. }
复制代码
输出结果
  1. 小于等于row010的行
  2. keyvalues={row001/data:col1/1364133382268/Put/vlen=7, row001/url:col1/1364133382268/Put/vlen=6}
  3. keyvalues={row002/data:col2/1364133382268/Put/vlen=7, row002/url:col2/1364133382268/Put/vlen=6}
  4. keyvalues={row003/data:col3/1364133382268/Put/vlen=7, row003/url:col3/1364133382268/Put/vlen=6}
  5. keyvalues={row004/data:col4/1364133382268/Put/vlen=7, row004/url:col4/1364133382268/Put/vlen=6}
  6. keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
  7. keyvalues={row006/data:col6/1364133382268/Put/vlen=7, row006/url:col6/1364133382268/Put/vlen=6}
  8. keyvalues={row007/data:col7/1364133382268/Put/vlen=7, row007/url:col7/1364133382268/Put/vlen=6}
  9. keyvalues={row008/data:col8/1364133382268/Put/vlen=7, row008/url:col8/1364133382268/Put/vlen=6}
  10. keyvalues={row009/data:col9/1364133382268/Put/vlen=7, row009/url:col9/1364133382268/Put/vlen=6}
  11. keyvalues={row010/data:col0/1364133382268/Put/vlen=7, row010/url:col0/1364133382268/Put/vlen=6}
  12. 正则获取结尾为5的行
  13. keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
  14. keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
  15. keyvalues={row025/data:col5/1364133382268/Put/vlen=7, row025/url:col5/1364133382268/Put/vlen=6}
  16. keyvalues={row035/data:col5/1364133382268/Put/vlen=7, row035/url:col5/1364133382268/Put/vlen=6}
  17. keyvalues={row045/data:col5/1364133382268/Put/vlen=7, row045/url:col5/1364133382268/Put/vlen=6}
  18. 包行有5的行
  19. keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
  20. keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
  21. keyvalues={row025/data:col5/1364133382268/Put/vlen=7, row025/url:col5/1364133382268/Put/vlen=6}
  22. keyvalues={row035/data:col5/1364133382268/Put/vlen=7, row035/url:col5/1364133382268/Put/vlen=6}
  23. keyvalues={row045/data:col5/1364133382268/Put/vlen=7, row045/url:col5/1364133382268/Put/vlen=6}
  24. keyvalues={row050/data:col0/1364133382268/Put/vlen=7, row050/url:col0/1364133382268/Put/vlen=6}
  25. 开头是row01的
  26. keyvalues={row010/data:col0/1364133382268/Put/vlen=7, row010/url:col0/1364133382268/Put/vlen=6}
  27. keyvalues={row011/data:col1/1364133382268/Put/vlen=7, row011/url:col1/1364133382268/Put/vlen=6}
  28. keyvalues={row012/data:col2/1364133382268/Put/vlen=7, row012/url:col2/1364133382268/Put/vlen=6}
  29. keyvalues={row013/data:col3/1364133382268/Put/vlen=7, row013/url:col3/1364133382268/Put/vlen=6}
  30. keyvalues={row014/data:col4/1364133382268/Put/vlen=7, row014/url:col4/1364133382268/Put/vlen=6}
  31. keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
  32. keyvalues={row016/data:col6/1364133382268/Put/vlen=7, row016/url:col6/1364133382268/Put/vlen=6}
  33. keyvalues={row017/data:col7/1364133382268/Put/vlen=7, row017/url:col7/1364133382268/Put/vlen=6}
  34. keyvalues={row018/data:col8/1364133382268/Put/vlen=7, row018/url:col8/1364133382268/Put/vlen=6}
  35. keyvalues={row019/data:col9/1364133382268/Put/vlen=7, row019/url:col9/1364133382268/Put/vlen=6}
复制代码

 

 
 
 
RowFilter用于过滤row key
Operator Description
LESS 小于
LESS_OR_EQUAL 小于等于
[EQUAL 等于
NOT_EQUAL 不等于
GREATER_OR_EQUAL 大于等于
GREATER 大于
NO_OP 排除所有

 

Comparator Description
BinaryComparator 使用Bytes.compareTo()比较
BinaryPrefixComparator 和BinaryComparator差不多，从前面开始比较
NullComparator Does not compare against an actual value but whether a given one is null, or not  null.
BitComparator Performs a bitwise comparison, providing a BitwiseOp class with OR, and XORoperators.
RegexStringComparator 正则表达式
SubstringComparator 把数据当成字符串，用contains()来判断

 

  • import java.io.IOException;
  • import org.apache.hadoop.conf.Configuration;
  • import org.apache.hadoop.hbase.HBaseConfiguration;
  • import org.apache.hadoop.hbase.HColumnDescriptor;
  • import org.apache.hadoop.hbase.HTableDescriptor;
  • import org.apache.hadoop.hbase.client.HBaseAdmin;
  • import org.apache.hadoop.hbase.client.HTable;
  • import org.apache.hadoop.hbase.client.Put;
  • 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.BinaryPrefixComparator;
  • import org.apache.hadoop.hbase.filter.CompareFilter;
  • import org.apache.hadoop.hbase.filter.Filter;
  • import org.apache.hadoop.hbase.filter.RegexStringComparator;
  • import org.apache.hadoop.hbase.filter.RowFilter;
  • import org.apache.hadoop.hbase.filter.SubstringComparator;
  • public class TestHbaseRowFilter {
  •         String tableName = "test_row_filter";
  •         Configuration config = HBaseConfiguration.create();
  •         /**
  •          * 部分代码来自hbase权威指南
  •          * @throws IOException
  •          */
  •         public void testRowFilter() throws IOException {
  •                 HTable table = new HTable(config, tableName);
  •                 Scan scan = new Scan();
  •                 System.out.println("小于等于row010的行");
  •                 Filter filter1 = new RowFilter(CompareFilter.CompareOp.LESS_OR_EQUAL,
  •                                 new BinaryComparator("row010".getBytes()));
  •                 scan.setFilter(filter1);
  •                 ResultScanner scanner1 = table.getScanner(scan);
  •                 for (Result res : scanner1) {
  •                         System.out.println(res);
  •                 }
  •                 scanner1.close();
  •                 System.out.println("正则获取结尾为5的行");
  •                 Filter filter2 = new RowFilter(CompareFilter.CompareOp.EQUAL,
  •                                 new RegexStringComparator(".*5[        DISCUZ_CODE_0        ]quot;));
  •                 scan.setFilter(filter2);
  •                 ResultScanner scanner2 = table.getScanner(scan);
  •                 for (Result res : scanner2) {
  •                         System.out.println(res);
  •                 }
  •                 scanner2.close();
  •                 System.out.println("包含有5的行");
  •                 Filter filter3 = new RowFilter(CompareFilter.CompareOp.EQUAL,
  •                                 new SubstringComparator("5"));
  •                 scan.setFilter(filter3);
  •                 ResultScanner scanner3 = table.getScanner(scan);
  •                 for (Result res : scanner3) {
  •                         System.out.println(res);
  •                 }
  •                 scanner3.close();
  •                 System.out.println("开头是row01的");
  •                 Filter filter4 = new RowFilter(CompareFilter.CompareOp.EQUAL,
  •                                 new BinaryPrefixComparator("row01".getBytes()));
  •                 scan.setFilter(filter4);
  •                 ResultScanner scanner4 = table.getScanner(scan);
  •                 for (Result res : scanner4) {
  •                         System.out.println(res);
  •                 }
  •                 scanner3.close();
  •         }
  •         /**
  •          * 初始化数据
  •          */
  •         public void init() {
  •                 // 创建表和初始化数据
  •                 try {
  •                         HBaseAdmin admin = new HBaseAdmin(config);
  •                         if (!admin.tableExists(tableName)) {
  •                                 HTableDescriptor htd = new HTableDescriptor(tableName);
  •                                 HColumnDescriptor hcd1 = new HColumnDescriptor("data");
  •                                 htd.addFamily(hcd1);
  •                                 HColumnDescriptor hcd2 = new HColumnDescriptor("url");
  •                                 htd.addFamily(hcd2);
  •                                 admin.createTable(htd);
  •                         }
  •                         HTable table = new HTable(config, tableName);
  •                         table.setAutoFlush(false);
  •                         int count = 50;
  •                         for (int i = 1; i <= count; ++i) {
  •                                 Put p = new Put(String.format("row%03d", i).getBytes());
  •                                 p.add("data".getBytes(), String.format("col%01d", i % 10)
  •                                                 .getBytes(), String.format("data%03d", i).getBytes());
  •                                 p.add("url".getBytes(), String.format("col%01d", i % 10)
  •                                                 .getBytes(), String.format("url%03d", i).getBytes());
  •                                 table.put(p);
  •                         }
  •                         table.close();
  •                 } catch (IOException e) {
  •                         e.printStackTrace();
  •                 }
  •         }
  •         /**
  •          * @param args
  •          * @throws IOException
  •          */
  •         public static void main(String[] args) throws IOException {
  •                 TestHbaseRowFilter test = new TestHbaseRowFilter();
  •                 test.init();
  •                 test.testRowFilter();
  •         }
  • }
    • 复制代码
    输出结果
  • 小于等于row010的行
  • keyvalues={row001/data:col1/1364133382268/Put/vlen=7, row001/url:col1/1364133382268/Put/vlen=6}
  • keyvalues={row002/data:col2/1364133382268/Put/vlen=7, row002/url:col2/1364133382268/Put/vlen=6}
  • keyvalues={row003/data:col3/1364133382268/Put/vlen=7, row003/url:col3/1364133382268/Put/vlen=6}
  • keyvalues={row004/data:col4/1364133382268/Put/vlen=7, row004/url:col4/1364133382268/Put/vlen=6}
  • keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row006/data:col6/1364133382268/Put/vlen=7, row006/url:col6/1364133382268/Put/vlen=6}
  • keyvalues={row007/data:col7/1364133382268/Put/vlen=7, row007/url:col7/1364133382268/Put/vlen=6}
  • keyvalues={row008/data:col8/1364133382268/Put/vlen=7, row008/url:col8/1364133382268/Put/vlen=6}
  • keyvalues={row009/data:col9/1364133382268/Put/vlen=7, row009/url:col9/1364133382268/Put/vlen=6}
  • keyvalues={row010/data:col0/1364133382268/Put/vlen=7, row010/url:col0/1364133382268/Put/vlen=6}
  • 正则获取结尾为5的行
  • keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row025/data:col5/1364133382268/Put/vlen=7, row025/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row035/data:col5/1364133382268/Put/vlen=7, row035/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row045/data:col5/1364133382268/Put/vlen=7, row045/url:col5/1364133382268/Put/vlen=6}
  • 包行有5的行
  • keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row025/data:col5/1364133382268/Put/vlen=7, row025/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row035/data:col5/1364133382268/Put/vlen=7, row035/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row045/data:col5/1364133382268/Put/vlen=7, row045/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row050/data:col0/1364133382268/Put/vlen=7, row050/url:col0/1364133382268/Put/vlen=6}
  • 开头是row01的
  • keyvalues={row010/data:col0/1364133382268/Put/vlen=7, row010/url:col0/1364133382268/Put/vlen=6}
  • keyvalues={row011/data:col1/1364133382268/Put/vlen=7, row011/url:col1/1364133382268/Put/vlen=6}
  • keyvalues={row012/data:col2/1364133382268/Put/vlen=7, row012/url:col2/1364133382268/Put/vlen=6}
  • keyvalues={row013/data:col3/1364133382268/Put/vlen=7, row013/url:col3/1364133382268/Put/vlen=6}
  • keyvalues={row014/data:col4/1364133382268/Put/vlen=7, row014/url:col4/1364133382268/Put/vlen=6}
  • keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
  • keyvalues={row016/data:col6/1364133382268/Put/vlen=7, row016/url:col6/1364133382268/Put/vlen=6}
  • keyvalues={row017/data:col7/1364133382268/Put/vlen=7, row017/url:col7/1364133382268/Put/vlen=6}
  • keyvalues={row018/data:col8/1364133382268/Put/vlen=7, row018/url:col8/1364133382268/Put/vlen=6}
  • keyvalues={row019/data:col9/1364133382268/Put/vlen=7, row019/url:col9/1364133382268/Put/vlen=6}
    • 复制代码

     

    RowFilter用于过滤row key

     

    Operator Description
    LESS 小于
    LESS_OR_EQUAL 小于等于
    [EQUAL 等于
    NOT_EQUAL 不等于
    GREATER_OR_EQUAL 大于等于
    GREATER 大于
    NO_OP 排除所有

     

    Comparator Description
    BinaryComparator 使用Bytes.compareTo()比较
    BinaryPrefixComparator 和BinaryComparator差不多，从前面开始比较
    NullComparator Does not compare against an actual value but whether a given one is null, or not  null.
    BitComparator Performs a bitwise comparison, providing a BitwiseOp class with OR, and XORoperators.
    RegexStringComparator 正则表达式
    SubstringComparator 把数据当成字符串，用contains()来判断


    1. import java.io.IOException;
    3. import org.apache.hadoop.conf.Configuration;
    4. import org.apache.hadoop.hbase.HBaseConfiguration;
    5. import org.apache.hadoop.hbase.HColumnDescriptor;
    6. import org.apache.hadoop.hbase.HTableDescriptor;
    7. import org.apache.hadoop.hbase.client.HBaseAdmin;
    8. import org.apache.hadoop.hbase.client.HTable;
    9. import org.apache.hadoop.hbase.client.Put;
    10. import org.apache.hadoop.hbase.client.Result;
    11. import org.apache.hadoop.hbase.client.ResultScanner;
    12. import org.apache.hadoop.hbase.client.Scan;
    13. import org.apache.hadoop.hbase.filter.BinaryComparator;
    14. import org.apache.hadoop.hbase.filter.BinaryPrefixComparator;
    15. import org.apache.hadoop.hbase.filter.CompareFilter;
    16. import org.apache.hadoop.hbase.filter.Filter;
    17. import org.apache.hadoop.hbase.filter.RegexStringComparator;
    18. import org.apache.hadoop.hbase.filter.RowFilter;
    19. import org.apache.hadoop.hbase.filter.SubstringComparator;
    21. public class TestHbaseRowFilter {
    22.         String tableName = "test_row_filter";
    23.         Configuration config = HBaseConfiguration.create();
    25.         /**
    26.          * 部分代码来自hbase权威指南
    27.          * @throws IOException
    28.          */
    29.         public void testRowFilter() throws IOException {
    31.                 HTable table = new HTable(config, tableName);
    32.                 Scan scan = new Scan();
    34.                 System.out.println("小于等于row010的行");
    35.                 Filter filter1 = new RowFilter(CompareFilter.CompareOp.LESS_OR_EQUAL,
    36.                                 new BinaryComparator("row010".getBytes()));
    37.                 scan.setFilter(filter1);
    38.                 ResultScanner scanner1 = table.getScanner(scan);
    39.                 for (Result res : scanner1) {
    40.                         System.out.println(res);
    41.                 }
    42.                 scanner1.close();
    44.                 System.out.println("正则获取结尾为5的行");
    45.                 Filter filter2 = new RowFilter(CompareFilter.CompareOp.EQUAL,
    46.                                 new RegexStringComparator(".*5[        DISCUZ_CODE_0        ]quot;));
    47.                 scan.setFilter(filter2);
    48.                 ResultScanner scanner2 = table.getScanner(scan);
    49.                 for (Result res : scanner2) {
    50.                         System.out.println(res);
    51.                 }
    52.                 scanner2.close();
    54.                 System.out.println("包含有5的行");
    55.                 Filter filter3 = new RowFilter(CompareFilter.CompareOp.EQUAL,
    56.                                 new SubstringComparator("5"));
    57.                 scan.setFilter(filter3);
    58.                 ResultScanner scanner3 = table.getScanner(scan);
    59.                 for (Result res : scanner3) {
    60.                         System.out.println(res);
    61.                 }
    62.                 scanner3.close();
    64.                 System.out.println("开头是row01的");
    65.                 Filter filter4 = new RowFilter(CompareFilter.CompareOp.EQUAL,
    66.                                 new BinaryPrefixComparator("row01".getBytes()));
    67.                 scan.setFilter(filter4);
    68.                 ResultScanner scanner4 = table.getScanner(scan);
    69.                 for (Result res : scanner4) {
    70.                         System.out.println(res);
    71.                 }
    72.                 scanner3.close();
    73.         }
    75.         /**
    76.          * 初始化数据
    77.          */
    78.         public void init() {
    79.                 // 创建表和初始化数据
    80.                 try {
    81.                         HBaseAdmin admin = new HBaseAdmin(config);
    82.                         if (!admin.tableExists(tableName)) {
    83.                                 HTableDescriptor htd = new HTableDescriptor(tableName);
    84.                                 HColumnDescriptor hcd1 = new HColumnDescriptor("data");
    85.                                 htd.addFamily(hcd1);
    86.                                 HColumnDescriptor hcd2 = new HColumnDescriptor("url");
    87.                                 htd.addFamily(hcd2);
    89.                                 admin.createTable(htd);
    90.                         }
    92.                         HTable table = new HTable(config, tableName);
    94.                         table.setAutoFlush(false);
    95.                         int count = 50;
    96.                         for (int i = 1; i <= count; ++i) {
    97.                                 Put p = new Put(String.format("row%03d", i).getBytes());
    98.                                 p.add("data".getBytes(), String.format("col%01d", i % 10)
    99.                                                 .getBytes(), String.format("data%03d", i).getBytes());
    100.                                 p.add("url".getBytes(), String.format("col%01d", i % 10)
    101.                                                 .getBytes(), String.format("url%03d", i).getBytes());
    102.                                 table.put(p);
    103.                         }
    104.                         table.close();
    106.                 } catch (IOException e) {
    107.                         e.printStackTrace();
    108.                 }
    109.         }
    111.         /**
    112.          * @param args
    113.          * @throws IOException
    114.          */
    115.         public static void main(String[] args) throws IOException {
    116.                 TestHbaseRowFilter test = new TestHbaseRowFilter();
    117.                 test.init();
    118.                 test.testRowFilter();
    119.         }
    121. }
    复制代码

     

    输出结果

     

    1. 小于等于row010的行
    2. keyvalues={row001/data:col1/1364133382268/Put/vlen=7, row001/url:col1/1364133382268/Put/vlen=6}
    3. keyvalues={row002/data:col2/1364133382268/Put/vlen=7, row002/url:col2/1364133382268/Put/vlen=6}
    4. keyvalues={row003/data:col3/1364133382268/Put/vlen=7, row003/url:col3/1364133382268/Put/vlen=6}
    5. keyvalues={row004/data:col4/1364133382268/Put/vlen=7, row004/url:col4/1364133382268/Put/vlen=6}
    6. keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
    7. keyvalues={row006/data:col6/1364133382268/Put/vlen=7, row006/url:col6/1364133382268/Put/vlen=6}
    8. keyvalues={row007/data:col7/1364133382268/Put/vlen=7, row007/url:col7/1364133382268/Put/vlen=6}
    9. keyvalues={row008/data:col8/1364133382268/Put/vlen=7, row008/url:col8/1364133382268/Put/vlen=6}
    10. keyvalues={row009/data:col9/1364133382268/Put/vlen=7, row009/url:col9/1364133382268/Put/vlen=6}
    11. keyvalues={row010/data:col0/1364133382268/Put/vlen=7, row010/url:col0/1364133382268/Put/vlen=6}
    12. 正则获取结尾为5的行
    13. keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
    14. keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
    15. keyvalues={row025/data:col5/1364133382268/Put/vlen=7, row025/url:col5/1364133382268/Put/vlen=6}
    16. keyvalues={row035/data:col5/1364133382268/Put/vlen=7, row035/url:col5/1364133382268/Put/vlen=6}
    17. keyvalues={row045/data:col5/1364133382268/Put/vlen=7, row045/url:col5/1364133382268/Put/vlen=6}
    18. 包行有5的行
    19. keyvalues={row005/data:col5/1364133382268/Put/vlen=7, row005/url:col5/1364133382268/Put/vlen=6}
    20. keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
    21. keyvalues={row025/data:col5/1364133382268/Put/vlen=7, row025/url:col5/1364133382268/Put/vlen=6}
    22. keyvalues={row035/data:col5/1364133382268/Put/vlen=7, row035/url:col5/1364133382268/Put/vlen=6}
    23. keyvalues={row045/data:col5/1364133382268/Put/vlen=7, row045/url:col5/1364133382268/Put/vlen=6}
    24. keyvalues={row050/data:col0/1364133382268/Put/vlen=7, row050/url:col0/1364133382268/Put/vlen=6}
    25. 开头是row01的
    26. keyvalues={row010/data:col0/1364133382268/Put/vlen=7, row010/url:col0/1364133382268/Put/vlen=6}
    27. keyvalues={row011/data:col1/1364133382268/Put/vlen=7, row011/url:col1/1364133382268/Put/vlen=6}
    28. keyvalues={row012/data:col2/1364133382268/Put/vlen=7, row012/url:col2/1364133382268/Put/vlen=6}
    29. keyvalues={row013/data:col3/1364133382268/Put/vlen=7, row013/url:col3/1364133382268/Put/vlen=6}
    30. keyvalues={row014/data:col4/1364133382268/Put/vlen=7, row014/url:col4/1364133382268/Put/vlen=6}
    31. keyvalues={row015/data:col5/1364133382268/Put/vlen=7, row015/url:col5/1364133382268/Put/vlen=6}
    32. keyvalues={row016/data:col6/1364133382268/Put/vlen=7, row016/url:col6/1364133382268/Put/vlen=6}
    33. keyvalues={row017/data:col7/1364133382268/Put/vlen=7, row017/url:col7/1364133382268/Put/vlen=6}
    34. keyvalues={row018/data:col8/1364133382268/Put/vlen=7, row018/url:col8/1364133382268/Put/vlen=6}
    35. keyvalues={row019/data:col9/1364133382268/Put/vlen=7, row019/url:col9/1364133382268/Put/vlen=6}
    复制代码

     

     

    相关文章：

    猜你喜欢
    相关资源
    相似解决方案
    热门标签
    Java Python linux javascript Mysql C# Docker 算法 前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库 数据结构 大数据 js 机器学习 微服务 Android Go 程序员 面试 JVM ASP.net core 云原生 人工智能 后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习 多线程 React 架构 devops 爬虫 云计算 Spring Boot LeetCode