Skip to main content

FetchHBaseRow

描述:

从HBase表中获取一行数据。其中《目标输出》参数指定是将HBase单元以JSON格式作为数据流的属性还是内容输出. 该组件可用于指定表和行ID来获取固定行,也支持通过输入数据流内容来动态指定需要获取的行

标签:

hbase, scan, fetch, get, enrich, 获取, 获得

参数:

如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.

名字默认值允许值列表描述
HBase客户端服务控制器服务API:
HBaseClientService
实现:
HBase_1_1_2_ClientService
指定用于访问HBase的配置服务
表名指定读取的HBase的表名

支持表达式语言 (支持流属性和变量)
行标识指定读取的行标识符

支持表达式语言 (支持流属性和变量)
指定读取由逗号分隔的<colFamily>:<colQualifier>对,为了返回所有列,可不指定列名(qualifier),仅提供列族(Family) <colFamily1>,<colFamily2>.

支持表达式语言 (支持流属性和变量)
授权指定给扫描器的授权列表,如果单元没有使用可见性标签,这将被忽略。

支持表达式语言 (支持流属性和变量)
目标输出数据流属性
- 数据流属性将读取到的行数据以JSON格式作为属性“hbase.row”输出。JSON文档的格式由《JSON格式》参数决定。  注意:如果将大量行数据作为属性将导致较大的性能问题
- 数据流内容将读取到的行数据以JSON格式输出到数据流中,JSON文档的格式由《JSON格式》参数决定。
指定读取行的数据输出策略
JSON格式全部行
- 全部行创建JSON文档为: {&quot;row&quot;:&lt;row-id&gt;, &quot;cells&quot;:[{&quot;fam&quot;:&lt;col-fam&gt;, &quot;qual&quot;:&lt;col-val&gt;, &quot;val&quot;:&lt;value&gt;, &quot;ts&quot;:&lt;timestamp&gt;}]}.
- 列名与值对创建JSON文档为:{&quot;&lt;col-qual&gt;&quot;:&quot;&lt;value&gt;&quot;, &quot;&lt;col-qual&gt;&quot;:&quot;&lt;value&gt;&quot;.
指定HBase行数据转换为JSON文档的方式
JSON值编码
- 无使用给定数据的字节和《编码》设置创建字符串
- base64创建给定数据的Base64编码字符串
指定行ID,列族,列名以及值输出的JSON编码
编码UTF-8指定用于编码行的JSON输出
解码UTF-8指定用于解码从HBase读取的数据

连线:

名字描述
success成功从HBase读取的数据输出到此连线
failure从HBase读取数据失败输出到此连线
not found在读取时行ID没有找到将输出到此连线

读取属性:

未提供。

写入属性:

名字描述
hbase.table获取行数据的表名
hbase.rowJSON格式的行数据,该属性仅当《目标输出》为数据流属性时有效
mime.type当《目标输出》设置为数据流内容输出时,设置为application/json,否则不设置

状态管理:

该组件不保存状态。

限制:

该组件没有限制

输入流要求:

组件必须提供输入流。

系统资源考量:

未提供。