Hbase Source
1. Introduce
Hbase Source
2. Version Support
hbase1.4
3. Connector Name
| Sync | hbasesource、hbasereader |
|---|---|
| SQL | hbase14-x |
4. Parameter description
1、SYNC
- table
- 描述:表名
- 必选:是
- 类型:String
- 默认值:无
- startRowkey
- 描述:rowKey起始点
- 必选:否
- 类型:String
- 默认值:无
- endRowkey
- 描述:rowKey结束点
- 必选:否
- 类型:String
- 默认值:无
- isBinaryRowkey
- 描述:rowkey是否是BytesBinary
- 必选:否
- 类型:Boolean
- 默认值:false
- scanCacheSize
- 描述:客户端rpc每次fetch最大行数
- 必选:否
- 类型:Long
- 默认值:1000
- encoding
- 描述:编码
- 必选:否
- 类型:string
- 默认值:utf-8
- hbaseConfig
- 描述:hbase-site里的相关配置 以及 kerberos相关配置
- 必选:是
- 类型:Map
- 默认值:无
- column
- 描述:需要读取的列族。
- 属性说明:
- name:字段名称
- type:字段类型,可以和数据库里的字段类型不一样,程序会做一次类型转换
- 必选:是
- 字段类型:List
- 默认值:无
2、SQL
- connector
- 描述:hbase14-x
- 必选:是
- 参数类型:String
- 默认值:无
- table-name
- 描述:表名
- 必选:是
- 参数类型:String
- 默认值:无:
- zookeeper.znode.parent
- 描述:hbase在zk的路径
- 必选:否
- 参数类型:string
- 默认值:/hbase
- zookeeper.quorum
- 描述:zk地址
- 必选:是
- 参数类型:String
- 默认值:无
- null-string-literal
- 描述:空值字符串代替
- 必选:否
- 默认值:"null"
- security.kerberos.principal
- 描述:kerberos的principal
- 必选:否
- 参数类型:String
- 默认值:无
- security.kerberos.keytab
- 描述:kerberos的keytab文件路径
- 必选:否
- 参数类型:String
- 默认值:无
- security.kerberos.krb5conf
- 描述:kdc的krb5conf配置文件
- 必选:否
- 参数类型:String
- 默认值:无
5. Data Type
| support | int |
|---|---|
| long | |
| double | |
| decimal | |
| objectId | |
| string | |
| bindata | |
| date | |
| timestamp | |
| bool | |
| no support | array |
6. Example
The details are in flinkx-examples dir.