首页 > Windows开发 > 详细

hbase的api操作之scan

时间:2019-04-22 23:45:25      阅读:210      评论:0      收藏:0      [点我收藏+]

扫描器缓存
----------------
    面向行级别的。
    @Test
    public void getScanCache() throws IOException {

        Configuration conf = HBaseConfiguration.create();
        Connection conn = ConnectionFactory.createConnection(conf);
        TableName tname = TableName.valueOf("ns1:t1");
        Scan scan = new Scan();
        scan.setCaching(5000);
        Table t = conn.getTable(tname);
        ResultScanner rs = t.getScanner(scan);
        long start = System.currentTimeMillis() ;
        Iterator<Result> it = rs.iterator();
        while(it.hasNext()){
            Result r = it.next();
            System.out.println(r.getColumnLatestCell(Bytes.toBytes("f1"), Bytes.toBytes("name")));
        }
        System.out.println(System.currentTimeMillis() - start);
    }
批量扫描是面向列级别
--------------------
    控制每次next()服务器端返回的列的个数。
    scan.setBatch(5);                //每次next返回5列。

 

hbase的api操作之scan

原文:https://www.cnblogs.com/zyanrong/p/10753798.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!