Hive 数据源

最近更新时间:2024-08-30 21:11:11

我的收藏
数据集成提供 Hive 的实时写入能力,本文为您介绍 Hive 实时数据同步当前能力支持情况。

支持版本

目前数据集成支持 Hive 整库及单表实时写入,使用实时写入能力需遵循以下版本限制:
类型
版本
Hive
1.x, 2.x, 3.x

使用限制

只支持 Append 写入,无法保证目标端数据不重。
不支持 DDL 变更,源端的 Schema 变更不会自动同步到目标端。
全量阶段自动建表不支持同步 comment 信息。

整库写入配置

支持的数据来源

当前支持将以下来源类型的数据实时整库同步到Hive目标端:

数据目标配置




参数
说明
数据去向
选择需要同步的目标数据源。
写入模式
Append:追加模式写入数据表(当前仅支持此模式)。
库/表匹配策略
Hive 中数据库以及数据表对象的名称匹配规则:
默认与来源库/来源表同名。
自定义:支持使用内置参数和字符串组合生成目标库表名称。
说明:
示例:如来源表名称为 table1,映射规则为 ${table_name_di_src}_inlong,则 table1 的数据将被最终映射写入至 table1_inlong 中。
目标库分区规则
系统时间分区:
时间粒度:单选,用户可选择四种时间格式:YYYYMMDD、YYYYMM、YYYY、YYYY-MM-DD HH。
指定字段分区:
时间粒度:单选,用户可选择四种时间格式:YYYYMMDD、YYYYMM、YYYY、YYYY-MM-DD HH。
分区字段名称:输入框,用户可输入作为分区字段的字段名称。此处必须是时间类型的字段。
不分区:不做分区处理。

单表写入配置




参数
说明
数据去向
需要写入的 Hive 数据源。
支持选择、或者手动输入需写入的库名称。
默认将数据源绑定的数据库作为默认库,其他数据库需手动输入库名称。
当数据源网络不联通导致无法直接拉取库信息时,可手动输入数据库名称。在数据集成网络连通的情况下,仍可进行数据同步。
支持选择、或者手动输入需写入的表名称。
当数据源网络不联通导致无法直接拉取表信息时,可手动输入表名称。在数据集成网络连通的情况下,仍可进行数据同步。
写入模式
Hive 仅支持 Append 写入
高级设置
可根据业务需求配置参数。

日志采集写入配置




参数
说明
数据源
选择当前项目中可用的 HIVE 数据源。
库/表
选择该数据源中对应的库表。
写入模式
Hive 仅支持 Append 写入。
高级设置(可选)
可根据业务需求配置参数。

写入数据类型转换支持

内部类型
Hive 类型
CHAR(p)
char(p)
VARCHAR(p)
varchar(p)
STRING
string
BOOLEAN
boolean
TINYINT
tinyint
SMALLINT
smallint
INT
int
BIGINT
bigint
FLOAT
float
DOUBLE
double
DECIMAL(p, s)
decimal(p, s)
DATE
date
TIMESTAMP
timestamp(9)
BINARY
bytes
LIST
array
MAP
map
STRUCT
row