zoukankan      html  css  js  c++  java

  • 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()来判断
    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()来判断


    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}
    复制代码
  • 相关阅读:
    重要的API运算函数
    Chicken的代码解剖 :4 ChickenPawn_Chicken一小部分
    Chicken的代码解剖：5 Chicken中的两个接口及其相关
    项目实例：深投控股star rating评分插件
    项目实例：深投控股JQueryXmlMenu
    编程经验：VS2008注册方法
    编程经验：SQL Server Management Studio使用注意事项
    程序员面试题精选100题（07）翻转句子中单词的顺序
    程序员面试100题精选（8）
    Ogre框架的搭建过程
  • 原文地址：https://www.cnblogs.com/seaspring/p/5631933.html
Copyright © 2011-2022 走看看