直接貼代碼啦

[java]?view plaincopy

/**?

?????*??

?????*?@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?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();??

????????}??

????????????

????}??

總結

以上是生活随笔為你收集整理的HBase-scan API 通过scan读取表中数据的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。