直接贴代码啦 /** * * @param zkIp * @param zkPort * @param tablename * @param startRow 传null扫全表 * @param stopRow 已~结尾 * @throws Exception */public static void scanTable(String zkIp,String zkPort,String tablename,String startRow,Strin
直接贴代码啦
/** * * @param zkIp * @param zkPort * @param tablename * @param startRow 传null扫全表 * @param stopRow 已~结尾 * @throws Exception */ public static void scanTable(String zkIp,String zkPort,String tablename,String startRow,String stopRow) throws Exception { HTablePool pool; Configuration config = HBaseConfiguration.create(); config.set("hbase.zookeeper.quorum",zkIp);// config.set("hbase.zookeeper.property.clientPort", zkPort); pool = new HTablePool(config, 2); HTableInterface hbTable = null; try { hbTable = pool.getTable(tablename); // 表名 ResultScanner rs = null; Scan scan = new Scan(); // scan.addColumn(Bytes.toBytes("cf1"),Bytes.toBytes("qual1"));扫某一列 if (startRow != null) { // 设置扫描的范围 scan.setStartRow(Bytes.toBytes(startRow)); } if (stopRow != null) { scan.setStopRow(Bytes.toBytes(stopRow)); } rs = hbTable.getScanner(scan); hbTable.close(); for (Result r : rs) {// 按行去遍历 for (KeyValue <p style="color:transparent">本文来源gao!%daima.com搞$代*!码$网3</p>kv : r.raw()) {// 遍历每一行的各列 StringBuffer sb = new StringBuffer() .append(Bytes.toString(kv.getRow())).append("\t") .append(Bytes.toString(kv.getFamily())) .append("\t") .append(Bytes.toString(kv.getQualifier())) .append("\t").append(Bytes.toString(kv.getValue())); System.out.println(sb.toString()); // kv.getRow() key // kv.getFamily() cf1 // kv.getQualifier() 列名 // kv.getValue() value } } } catch (Exception e) { System.out.println(e.getMessage()); }finally{ pool.close(); } }
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：HBase-scanAPI通过scan读取表中数据
转载请注明原文链接：HBase-scanAPI通过scan读取表中数据
