hbase轻量级中间件simplehbase v1.0简介

zhang_xzhi 发布于 2014/12/13 19:42
阅读 793
收藏 6
[url]https://github.com/zhang-xzhi/simplehbase/[/url]
[url]https://github.com/zhang-xzhi/simplehbase/wiki[/url]


simplehbase的主要功能

数据类型映射:java类型和hbase的bytes之间的数据转换。
简单操作封装:封装了hbase的put,get,scan等操作为简单的java操作方式。
hbase query封装:封装了hbase的filter,可以使用sql-like的方式操作hbase。
动态query封装:类似于myibatis,可以使用xml配置动态语句查询hbase。
insert,update支持: 建立在hbase的checkAndPut之上。
hbase多版本支持:提供接口可以对hbase多版本数据进行查询,映射。
hbase批量操作支持。
hbase原生接口支持。
HTablePool管理。
HTable count和sum功能。




V1.0发布note.

Data Object需要被simpleHbase识别,除了原有annotation方式,新增POJO和xml配置方式。

新增count的实现,count时可以limit。

public long count(RowKey startRowKey, RowKey endRowKey,
@Nullable AggregateExtInfo aggregateExtInfo);
public long count(RowKey startRowKey, RowKey endRowKey,
@Nullable String id, @Nullable Map para,
@Nullable AggregateExtInfo aggregateExtInfo);

新增countAndSum。

public long[] countAndSum(RowKey startRowKey, RowKey endRowKey);
public long[] countAndSum(RowKey startRowKey, RowKey endRowKey,
@Nullable AggregateExtInfo aggregateExtInfo);
public long[] countAndSum(RowKey startRowKey, RowKey endRowKey,
@Nullable String id, @Nullable Map para);
public long[] countAndSum(RowKey startRowKey, RowKey endRowKey,
@Nullable String id, @Nullable Map para,
@Nullable AggregateExtInfo aggregateExtInfo);

新增batch get功能。

public List findObjectBatch(List rowKeyList,Class<? extends T> type);
public List> findObjectAndKeyBatch(List rowKeyList, Class<? extends T> type);

增加异常描述family和qualifier,rowKeyHandler,方便问题排查。

调整测试代码。
加载中
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部