直接贴代码啦

[java]  view plain copy 在CODE上查看代码片 派生到我的代码片
  1. /**
  2.      * 
  3.      * @param zkIp
  4.      * @param zkPort
  5.      * @param tablename
  6.      * @param startRow   传null扫全表
  7.      * @param stopRow 已~结尾
  8.      * @throws Exception
  9.      */
  10.     public static void scanTable(String zkIp,String zkPort,String tablename,String startRow,String stopRow) throws Exception {
  12.         HTablePool pool;
  13.         Configuration config = HBaseConfiguration.create();
  14.         config.set(“hbase.zookeeper.quorum”,zkIp);//
  15.         config.set(“hbase.zookeeper.property.clientPort”, zkPort);
  16.         pool = new HTablePool(config, 2);
  18.         HTableInterface hbTable = null;
  19.         try {
  20.             hbTable = pool.getTable(tablename); // 表名
  21.             ResultScanner rs = null;
  22.             Scan scan = new Scan();
  23.             // scan.addColumn(Bytes.toBytes(“cf1”),Bytes.toBytes(“qual1”));扫某一列
  24.             if (startRow != null) { // 设置扫描的范围
  25.                 scan.setStartRow(Bytes.toBytes(startRow));
  26.             }
  27.             if (stopRow != null) {
  28.                 scan.setStopRow(Bytes.toBytes(stopRow));
  29.             }
  31.             rs = hbTable.getScanner(scan);
  32.             hbTable.close();
  33.             for (Result r : rs) {// 按行去遍历
  34.                 for (KeyValue kv : r.raw()) {// 遍历每一行的各列
  35.                     StringBuffer sb = new StringBuffer()
  36.                             .append(Bytes.toString(kv.getRow())).append(“\t”)
  37.                             .append(Bytes.toString(kv.getFamily()))
  38.                             .append(“\t”)
  39.                             .append(Bytes.toString(kv.getQualifier()))
  40.                             .append(“\t”).append(Bytes.toString(kv.getValue()));
  41.                     System.out.println(sb.toString());
  42.                     // kv.getRow() key
  43.                     // kv.getFamily() cf1
  44.                     // kv.getQualifier() 列名
  45.                     // kv.getValue() value
  47.                 }
  49.             }
  51.         } catch (Exception e) {
  52.             System.out.println(e.getMessage());
  53.         }finally{
  54.             pool.close();
  55.         }
  57.     }