现在的位置: 首页 > 综合 > 正文

HBase概念学习(五)Java API之计数器

2019年10月14日 ⁄ 综合 ⁄ 共 721字 ⁄ 字号 评论关闭

本文为阅读《Hbase权威指南》后笔记。

1、计数器简介

之前在介绍Put和Delete的时候说道过检查并修改(Check and modify),计数器类似,也是为了防止多个客户端的资源竞争导致不一致。

如果没有计数器,用户需要针对一行加锁,读取一行的值,然后再加上特定的值,然后再写回并释放锁,尤其是当客户端进程崩溃之后,尚未释放的锁需要等待超时恢复,这样在一个高负载的系统中会引起灾难性后果。

计数器就是读取并修改(Read and modify),保证一次客户端操作的原子性。


下面是一个创建一列,并作为计数器进行累加的例子:

关于计数器的初始化:

用户不用初始化计数器,第一次使用的时候会被自动设置为0。

可以看到增加计数器使用incr命令(可以增加任意值),获取计数器用get_counter命令。

编写Java程序的时候你可以用Put直接给一个计数器赋值,但是你必须使用Bytes.toBytes(long)方法来给要设定的值进行编码,否则会得到意想不到的结果。同样你可以使用Get直接来获取计数器的值,但是你必须使用Bytes.toLong()来进行解码。

2、使用一个计数器

下面的操作只能操作一个计数器,即一列,需要指定列族和列限定名,以及要增加的值(可以为正数、0、负数)


下面是使用实例:

3、使用多个计数器

用户可以一次更新多个计数器,但是它们都必须属于一行。更多的行的计数器需要使用独立的API调用,即多个RPC请求。Batch()方法目前并不支持Increment实例。

和Get、Put、Delete类似,HTable也提供了一个操作计数器实例的方法:


创建Increment实例,以及往其中加入实际的计数器的方法是:


下面是一个使用多个计数器的例子:

抱歉!评论已关闭.