hbase分頁查詢實(shí)現(xiàn)-

1、hbase分頁查詢實(shí)現(xiàn)Hbase本身是沒有分頁查詢的，我在網(wǎng)上找了很多資料來實(shí)現(xiàn)一個(gè)分頁功能，在這里做了一下記錄，分享給大家，有什么不足之處，請(qǐng)盡管指出。廢話不多說，看代碼。imptimptjava.io.IOExceptionimptimptjava.util.LinkedHashMapimptimptjava.util.LinkedListimptimptjava.util.Listimptimptjava.util.Mapimpt

2、imptg.mons.lang.StringUtilsimptimptg.apache.hadoop.conf.Configurationimptimptg.apache.hadoop.hbase.HBaseConfigurationimptimptg.apache.hadoop.hbase.client.Getimptimptg.apache.hadoop.hbase.client.HTableInterfaceimptimptg.a

3、pache.hadoop.hbase.client.HTablePoolimptimptg.apache.hadoop.hbase.client.Resultimptimptg.apache.hadoop.hbase.client.ResultScannerimptimptg.apache.hadoop.hbase.client.Scanimptimptg.apache.hadoop.hbase.pareOpimptimptg.apac

4、he.hadoop.hbase.filter.Filterimptimptg.apache.hadoop.hbase.filter.FilterListimptimptg.apache.hadoop.hbase.filter.FirstKeyOnlyFilterimptimptg.apache.hadoop.hbase.filter.SingleColumnValueFilterimptimptg.apache.hadoop.hbase

5、.util.BytespublicpublicclassclassHBaseUtilsprivateprivatestaticstaticConfigurationconfig=nullnullprivateprivatestaticstaticHTablePooltp=nullnullstaticstatic加載集群配置config=HBaseConfiguration.create()config.set(“hbase.zookee

6、per.quum““xx.xx.xx“)config.set(“hbase.zookeeper.property.clientPt““2181“)創(chuàng)建表池(可偉略提高查詢性能，具體說明請(qǐng)百度或官方API)tp=newnewHTablePool(config10)獲取hbase的表IntegerendPage=firstPagepageSize從表池中取出HBASE表對(duì)象HTableInterfacetable=getTable(tabl

7、eName)獲取篩選對(duì)象Scanscan=getScan(startRowstopRow)給篩選對(duì)象放入過濾器(true標(biāo)識(shí)分頁具體方法在下面)scan.setFilter(packageFilters(truetrue))緩存1000條數(shù)據(jù)scan.setCaching(1000)scan.setCacheBlocks(falsefalse)scanner=table.getScanner(scan)intinti=0ListrowL

8、ist=newnewLinkedList()遍歷掃描器對(duì)象，并將需要查詢出來的數(shù)據(jù)rowkey取出ff(Resultresult:scanner)Stringrow=toStr(result.getRow())ifif(i=firstPageResult[]results=table.get(getList)遍歷結(jié)果ff(Resultresult:results)Mapfmap=packFamilyMap(result)Maprmap=

9、packRowMap(fmap)mapList.add(rmap)封裝分頁對(duì)象tbData=newnewTBData()tbData.setCurrentPage(currentPage)tbData.setPageSize(pageSize)tbData.setTotalCount(i)tbData.setTotalPage(getTotalPage(pageSizei))tbData.setResultList(mapList)ca