Skip to content

Latest commit

 

History

History
121 lines (109 loc) · 2.8 KB

hbase-client.md

File metadata and controls

121 lines (109 loc) · 2.8 KB
Raw

camellia-hbase

简介

基于camellia-core和hbase-client开发的hbase客户端CamelliaHBaseTemplate

feature

  • enhanced hbase client
  • base on camellia-core and hbase-client，main class is CamelliaHBaseTemplate
  • support client read-write-separate/double-write

特性

  • 多读多写（如读写分离、双写等）
  • 支持配置在线修改（需整合camellia-dashboard）
  • 提供了一个spring-boot-starter，快速接入

使用场景

  • 需要进行hbase双写迁移

maven依赖

  • spring-boot-starter（spring自动注入CamelliaHBaseTemplate对象）
<dependency>
  <groupId>com.netease.nim</groupId>
  <artifactId>camellia-hbase-spring-boot-starter</artifactId>
  <version>a.b.c</version>
</dependency>
  • 直接使用（需要你自己new一个CamelliaHBaseTemplate对象）
<dependency>
  <groupId>com.netease.nim</groupId>
  <artifactId>camellia-hbase</artifactId>
  <version>a.b.c</version>
</dependency>

支持的命令

参考ICamelliaHBaseTemplate接口定义

示例（详细配置参考CamelliaHBaseProperties）

使用本地配置（基于xml）

camellia-hbase:
  type: local
  local:
    xml:
      xml-file: hbase.xml

使用本地配置（基于yml）

camellia-hbase:
  type: local
  local:
    conf-type: yml
    yml:
      resource: hbase://xxx1.163.org,xxx2.163.org,xxx3.163.org/hbase

使用本地配置（复杂配置，单独的一个json文件）

camellia-hbase:
  type: local
  local:
    conf-type: yml
    yml:
      type: complex
      json-file: resource-table.json

{
  "type": "simple",
  "operation": {
    "read": "hbase://xxx1.163.org,xxx2.163.org,xxx3.163.org/hbase",
    "type": "rw_separate",
    "write": {
      "resources": [
        "hbase://xxx1.163.org,xxx2.163.org,xxx3.163.org/hbase",
        "hbase://yyy1.163.org,yyy2.163.org,yyy3.163.org/hbase"
      ],
      "type": "multi"
    }
  }
}

使用dashboard动态配置

camellia-hbase:
  type: remote
  remote:
    bid: 1
    bgroup: default
    url: http://127.0.0.1:8080

客户端使用

//PUT操作
Put put = new Put(Bytes.toBytes("rowKey"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("qualifier"), Bytes.toBytes("value"));
template.put("hbase_table_name", put);

//DELETE操作
Delete delete = new Delete(Bytes.toBytes("rowKey"));
template.delete("hbase_table_name", delete);

//GET操作
Get get = new Get(Bytes.toBytes("rowKey"));
Result result = template.get("hbase_table_name", get);
//parse result

//SCAN操作
Scan scan = new Scan(Bytes.toBytes("startRowKey"), Bytes.toBytes("endRowKey"));
scan.setCaching(50);
scan.setSmall(true);
ResultScanner resultScanner = template.scan("hbase_table_name", scan);
for (Result result1 : resultScanner) {
//parse result1
}

示例源码

示例源码