hbase java Api Scan Limit ----小短文（含分页实现思路）_我要用代码向我喜欢的女孩表白_hbase java scan

大大的周 02-07 4249

注意:Hbase 1.4x以上的API才支持Limit

写之前在国内百度找烂了，没有找到Limit。最后在国外stackOverFlow找到了，说明是版本问题。

然后我就改了2.0，发现是支持的，但是以前的代码就不支持了，而且也得换库。所以我就1个1个的试，看看哪个版本，既能兼容以前的代码也能有这个功能。

最后试出来了，1.4.0开始支持这个方法了。

为了版本不冲突，选取的hbase程序是官方推荐的1.7，pom也是1.7。花了2分钟替换了一下程序和配置。就可以用了。

分页功能实现，startRow与Limit，可完成分页。Hbase默认scan是进行排序的。

如果想取前1w行，则指定startRow,并且limit 10001。可以作为第一页。取末尾最后一个row，作为下一个的startRow。可实现分页。

hbase shell：

由于【rowStart和endRow】的获取速度和你get一样快，固常用于【Hbase迁移】，和更新。用于记录迁移的位置和【断点续传】。

javaApi:

pom、和基本配置连接我就不给了，我的另一篇博文有。传送门

@Test public void cpNewLibaryToken(){ //rowkey String rowStrat="0";//选取你scan的第一个rowkey的第一个字符 //hbase 数据获取 Configuration HBASE_CONF; HBASE_CONF = HBaseConfiguration.create(); HBASE_CONF.set("hbase.zookeeper.property.clientPort", "2181"); HBASE_CONF.set("hbase.zookeeper.quorum", "192.168.xx.xx"); HBASE_CONF.set("hbase.master", "192.168.xx.xx:60000"); HBASE_CONF.set("zookeeper.znode.parent", "/hbase"); HBASE_CONF.setInt("hbase.hconnection.threads.max", 5); HBASE_CONF.setInt("hbase.hconnection.threads.core", 5); HBASE_CONF.setLong("hbase.hconnection.threads.keepalivetime", 1000); System.out.println("连接hbase"); try { ConnectionFactory.createConnection(HBASE_CONF); Connection hbaseConnection = ConnectionFactory.createConnection(HBASE_CONF); Table tableRead = hbaseConnection.getTable(TableName.valueOf("0_library_token")); System.out.println("开始读取"+rowStrat+"后的1w个rowKey"); Scan scan = new Scan().withStartRow(rowStrat.getBytes())//这个和低版本略有不同 .setMaxVersions(99999999).setMaxResultsPerColumnFamily(10) .addColumn(Bytes.toBytes("F"), Bytes.toBytes("F")) .setLimit(10);//这个就是核心，对应shell中的limit，数字代表startRow后面的条数 ResultScanner scanner = tableRead.getScanner(scan); for(Result rs:scanner){ String row = Bytes.toString(rs.getRow()); System.out.println(row); } } catch (Exception e){ e.printStackTrace(); System.out.println("Hbase进行"+rowStrat+"这后面的1w个rowkey时，失败"); System.out.println("进行失败脏数据删除中-----------"); //删除代码（我在demo中删除了，这个根据自己的业务来） System.out.println("删除完成---------"); } }