# HBase11X Writer

HbaseWriter 插件实现了从向Hbase中写取数据。在底层实现上，HbaseWriter 通过 HBase 的 Java 客户端连接远程 HBase 服务，并通过 put 方式写入Hbase。

如果 HBase 是 2.X 版本，则需要使用 [HBase20xsqlwriter](../hbase20xsqlwriter) 插件

## 配置样例

配置一个从本地写入hbase1.1.x的作业：

`json --8<-- "jobs/hbase11xwriter.json" `

## 参数说明

配置项          | 是否必须 | 默认值 | 描述                                                                                                                              |
:-------------- | :------: | ------ | --------------------------------------------------------------------------------------------------------------------------------- |
hbaseConfig     |    是    | 无     | 连接  HBase 集群需要的配置信息,JSON格式, hbase.zookeeper.quorum 为必填项，其他 HBase client的配置为可选项                             |
mode            |    是    | 无     | 写入 HBase 的模式，目前仅支持 normal 模式                                                                                         |
table           |    是    | 无     |  HBase 表名（大小写敏感）                                                                                                 |
encoding        |    否    | UTF-8  | 编码方式，UTF-8 或是 GBK，用于对二进制存储的 HBase byte[] 转为 String 时的编码                                                  |
column          |    是    | 无     | 要写入的字段，normal 模式与  multiVersionFixedColumn 模式下必填项, 详细说明见下文                                              |
rowkeyColumn    |    是    | 无     | 要写入的 rowkey 列, 详细说明见下文                                                                                           |
versionColumn   |    否    | 无     | 指定写入的时间戳。支持：当前时间、指定时间列，指定时间，三者选一,详见下文                                                    |
nullMode        |    否    | skip   | 读取的null值时，如何处理, skip 表示不向hbase写这列；empty：写入 HConstants.EMPTY_BYTE_ARRAY，即`new byte [0]`               |
walFlag         |    否    | false  | 是否写 WAL, true 表示写入, false 表示不写                                                                                           |
writeBufferSize |    否    | 8M     | 设置写 buffer 大小，单位字节                                                                                           |
maxVersion      |    是    | 无     | 指定在多版本模式下读取的版本数，-1 表示读取所有版本, multiVersionFixedColumn 模式下必填 |
range           |    否    | 无     | 指定读取的 rowkey 范围, 详见下文                                                                                         |
scanCacheSize   |    否    | 256    | 每次从服务器端读取的行数                                                                                           |
scanBatchSize   |    否    | 100    | 每次从服务器端读取的列数                                                                                           |

### column

要写入的hbase字段。index：指定该列对应reader端column的索引，从0开始；name：指定hbase表中的列，必须为列族:列名的格式；type：指定写入数据类型，用于转换HBase byte[]。配置格式如下：

```json {

"column": [

{
"index": 1, "name": "cf1:q1", "type": "string"

}, {

"index": 2, "name": "cf1:q2", "type": "string"

}

]

}

### rowkey

要写入的 rowkey 列。index：指定该列对应reader端column的索引，从0开始，若为常量index为－1；type：指定写入数据类型，用于转换HBase byte[]；value：配置常量，常作为多个字段的拼接符。hbasewriter会将rowkeyColumn中所有列按照配置顺序进行拼接作为写入hbase的rowkey，不能全为常量。配置格式如下：

```json {