hbase之setCaching 和 setBatch 和setMaxResultSize

连接

scan的setBatch()用法

        val conf = HBaseConfiguration.create()
        val table: Table = ConnectionFactory.createConnection(conf).getTable(TableName.valueOf(Bytes.toBytes("user")))

        val scan = new Scan()
        scan.addColumn(Bytes.toBytes("info"),Bytes.toBytes("gender"))
        scan.setBatch(2)

        val scanner: ResultScanner = table.getScanner(scan)
        var res = scanner.next()
        while (res!=null){
           println(res.listCells().size())
            res = scanner.next()
        }

1. 获取hbase连接
2. 获取表的句柄
3. 获取scanner
4. 通过scanner的next的方法获取result，每个result的包含多少cell由Batch决定：
   当batch小于列数，则每个result的cell数等于batch
   当batch大于列数，则每个result的cell数等于列数
   写成公式：
   Result 包含的cell数 = Min(每行列数，Batch大小)
   Result 的个数 =（ row数 * 每行的列数 ）/ Min(每行列数，Batch大小)

scan的setCaching()用法
hbase权威指南提供了一个表，如下图所示

根据上面的表得到公式：
rpc次数 = result数量/缓存数 + 1
有些博客说Caching的值代表行数，这种说法是不完全正确的，而且这里的Caching不能无限制的大，因为hbase的每个rpc是有时间限制的，固定的时间如果值读取不完会出现连接异常。