普元数据集成平台 普元数据集成平台
产品介绍
安装部署
快速入门
操作指南
FAQ
  • HBase Sink组件使用说明
  • 组件说明
  • 配置项说明
  • FAQ

# HBase Sink组件使用说明

  • 组件说明
  • 配置项说明
  • 使用示例
    • 将Mysql的数据写入HBase中
  • FAQ

# 组件说明

HBase Sink 连接器。用于将数据写入 HBase、Hyperbase 数据库。Hyperbase数据库也使用Hbase Sink组件。

# 配置项说明

配置名称 数据类型 是否必填 默认值 描述
节点名称 String 是 - 当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。
节点编码 String 是 - 当前创建的节点编码,以此标识此组件,由用户自定义且不可为空。命名可包含字母、数字、下划线。
选择数据源 String 是 - 从下拉选项中选择列出的当前项目已经关联的数据源。
选择表 String 是 - 从下拉列表中选择数据表。
Rowkey取值列 String 否 "" 连接多行键的分隔符,默认为""。
映射配置 String 是 - 字段与列族的映射,例如:Id作为行键和其他字段写入到不同的列族,您可以分配 family_name { name = "info1" age = "info2" } name将写入列族info1,age将写入列族info2 如果您希望将所有字段写入同一列族,你可以分配 family_name { all_columns = "info" } 所有字段都将写入列族info。
空值写入模式 String 否 skip 空值写入方式,支持[skip, empty],默认跳过 skip:当字段为 null 时,连接器不会将此字段写入 hbase empty:当字段为null时,连接器将写入并为此字段生成空值。
Write Ahead Log写入 Boolean 否 否 HBase 采用了 Write-Ahead Log (WAL) 机制来保证数据的持久性和容错性。
版本列名 String 否 - 可以使用它来为hbase记录分配时间戳。
缓冲区大小 String 否 8 HBase 客户端写缓冲区大小。
编码 String 否 utf8 字符串类型字段的编码,支持[utf8,gbk],默认为utf8。
可选参数 否 - 其他参数,用户可以根据需求进行配置。

# FAQ

← Elasticsearch Hive →