Skip to main content

Hbase Source

1. Introduce

Hbase Source

2. Version Support

hbase1.4

3. Connector Name

Synchbasesource、hbasereader
SQLhbase14-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

supportint
long
double
decimal
objectId
string
bindata
date
timestamp
bool
no supportarray

6. Example

The details are in flinkx-examples dir.