PrimetonDWS

Appearance

操作指南/开发示例/开发转换示例/Hive输出-列映射使用

Hive输出-列映射使用 ​

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

主要步骤如下：

提示

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

模型 ​

input

准备数据 ​

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

sql
drop table dept;

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

开发步骤 ​

步骤1：生成记录 ​

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

generate

步骤2：基础配置 ​

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

config

列映射配置说明：

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

mapping

步骤3：运行结果 ​

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

run

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

result