Hive输出-列映射使用

通过上游传入字段与目标表字段绑定进行值存储。

主要步骤如下：

• 模型
• 开发步骤
  • 准备数据
  • 生成记录
  • 基础配置
  • 运行结果

提示

• 确保目标表已创建且结构正确
• 列映射需保证字段类型兼容
• 写入大量数据时注意配置批量提交参数
• 分区表需正确配置分区字段

模型

准备数据

在目标数据库中创建 Hive 表。

drop table dept;

CREATE TABLE `dept` (
    `deptno` STRING,
    `deptname` STRING,
    `loc` STRING)
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
    STORED AS ORC;

开发步骤

步骤1：生成记录

从「输入」分组拖出「生成记录」组件进行数据配置。

步骤2：基础配置

1. 勾选「指定数据库字段」选项
2. 获取字段
3. 点击「列映射」进入配置页面

列映射配置说明：

• 手动映射：需要手动选择来源字段，目标字段进行映射匹配
• 自动同名映射：名称相同的字段会自动添加到下方的映射关系中
• 重置映射：清除下方映射关系

步骤3：运行结果

点击「保存」→「提交」→「运行」。

验证：查询数据库，数据已被插入表中。