文档首页/ MapReduce服务 MRS/ 组件操作指南（LTS版）(巴黎区域)/ 使用Loader/ 算子帮助/ 输出算子/ 表输出
更新时间：2022-12-14 GMT+08:00
查看PDF
分享

表输出

概述

“表输出”算子，用于配置输出的字段对应到关系型数据库的指定列。

输入与输出

  • 输入：需要输出的字段
  • 输出：关系型数据库表

参数说明

表1 算子参数说明

参数

含义

类型

是否必填

默认值

输出分隔符

配置分隔符。

说明：

该配置仅用于MySQL专用连接器，当数据列内容中包含默认分隔符时，需要设置自定义分隔符，否则会出现数据错乱。

string

否

,

换行分隔符

用户根据数据实际情况，填写字符串作为换行符。支持任何字符串。默认使用操作系统的换行符。

说明：

该配置仅用于MySQL专用连接器，当数据列内容中包含默认分隔符时，需要设置自定义分隔符，否则会出现数据错乱。

string

否

\n

输出字段

配置关系型数据库输出字段的相关信息：

  • 字段名：配置输出字段的字段名。
  • 表列名：配置数据库表的列名。
  • 类型：配置字段类型，需要和数据库的字段类型一致。
  • 长度：配置字段长度，字段值实际长度太长则按配置的长度截取，“类型”为“CHAR”时实际长度不足则空格补齐，“类型”为“VARCHAR”时实际长度不足则不补齐。

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表中：

输出结果如下：

父主题： 输出算子