表输出
概述
“表输出”算子,用于配置输出的字段对应到关系型数据库的指定列。
输入与输出
- 输入:需要输出的字段
- 输出:关系型数据库表
参数说明
参数 | 含义 | 类型 | 是否必填 | 默认值 |
|---|---|---|---|---|
输出分隔符 | 配置分隔符。 说明: 该配置仅用于MySQL专用连接器,当数据列内容中包含默认分隔符时,需要设置自定义分隔符,否则会出现数据错乱。 | string | 否 | , |
换行分隔符 | 用户根据数据实际情况,填写字符串作为换行符。支持任何字符串。默认使用操作系统的换行符。 说明: 该配置仅用于MySQL专用连接器,当数据列内容中包含默认分隔符时,需要设置自定义分隔符,否则会出现数据错乱。 | string | 否 | \n |
输出字段 | 配置关系型数据库输出字段的相关信息:
| map | 是 | 无 |
数据处理规则
将字段值输出到表中。
样例
以HBase导出到sqlserver2014数据库为例。
在sqlserver2014上创建一张空表test_1用于存储HBase数据。执行以下语句:
create table test_1 (id int, name text, value text);
通过HBase输入步骤,生成三个字段A、B和C。
配置“表输出”算子,将A、B和C输出到test_1表中:

输出结果如下:


