腾讯云数据仓库 TCHouse-D
有奖捉虫：办公协同&微信生态&物联网文档专题 HOT
文档中心 > 腾讯云数据仓库 TCHouse-D > 开发指南 > 生态扩展功能 > 外表 > Hive 外表

Hive 外表

最近更新时间：2023-12-08 10:38:41

我的收藏

本页目录：

说明：
本文档展示的内容仅适用于 Doris 1.1及以下版本，后续版本建议使用 Multi-Catalog 功能对接外部数据目录。
Hive External Table of Doris 提供了 Doris 直接访问 Hive 外部表的能力，外部表省去了繁琐的数据导入工作，并借助 Doris 本身的 OLAP 的能力来解决 Hive 表的数据分析问题：
1. 支持 Hive 数据源接入Doris。
2. 支持 Doris 与 Hive 数据源中的表联合查询，进行更加复杂的分析操作。
3. 支持 访问开启 Kerberos 的 Hive 数据源。
本文档主要介绍该功能的使用方式和注意事项等。

使用方法

Doris 中创建 Hive 的外表

-- 语法
CREATE [EXTERNAL] TABLE table_name (
  col_name col_type [NULL | NOT NULL] [COMMENT "comment"]
) ENGINE=HIVE
[COMMENT "comment"]
PROPERTIES (
  'property_name'='property_value',
  ...
);

-- 例子1：创建 Hive 集群中 hive_db 下的 hive_table 表
CREATE TABLE `t_hive` (
  `k1` int NOT NULL COMMENT "",
  `k2` char(10) NOT NULL COMMENT "",
  `k3` datetime NOT NULL COMMENT "",
  `k5` varchar(20) NOT NULL COMMENT "",
  `k6` double NOT NULL COMMENT ""
) ENGINE=HIVE
COMMENT "HIVE"
PROPERTIES (
'hive.metastore.uris' = 'thrift://192.168.0.1:9083',
'database' = 'hive_db',
'table' = 'hive_table'
);

-- 例子2：创建 Hive 集群中 hive_db 下的 hive_table 表,HDFS使用HA配置
CREATE TABLE `t_hive` (
  `k1` int NOT NULL COMMENT "",
  `k2` char(10) NOT NULL COMMENT "",
  `k3` datetime NOT NULL COMMENT "",
  `k5` varchar(20) NOT NULL COMMENT "",
  `k6` double NOT NULL COMMENT ""
) ENGINE=HIVE
COMMENT "HIVE"
PROPERTIES (
'hive.metastore.uris' = 'thrift://192.168.0.1:9083',
'database' = 'hive_db',
'table' = 'hive_table',
'dfs.nameservices'='hacluster',
'dfs.ha.namenodes.hacluster'='n1,n2',
'dfs.namenode.rpc-address.hacluster.n1'='192.168.0.1:8020',
'dfs.namenode.rpc-address.hacluster.n2'='192.168.0.2:8020',
'dfs.client.failover.proxy.provider.hacluster'='org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider'
);

-- 例子3：创建 Hive 集群中 hive_db 下的 hive_table 表, HDFS使用HA配置并开启kerberos认证方式
CREATE TABLE `t_hive` (
  `k1` int NOT NULL COMMENT "",
  `k2` char(10) NOT NULL COMMENT "",
  `k3` datetime NOT NULL COMMENT "",
  `k5` varchar(20) NOT NULL COMMENT "",
  `k6` double NOT NULL COMMENT ""
) ENGINE=HIVE
COMMENT "HIVE"
PROPERTIES (
'hive.metastore.uris' = 'thrift://192.168.0.1:9083',
'database' = 'hive_db',
'table' = 'hive_table',
'dfs.nameservices'='hacluster',
'dfs.ha.namenodes.hacluster'='n1,n2',
'dfs.namenode.rpc-address.hacluster.n1'='192.168.0.1:8020',
'dfs.namenode.rpc-address.hacluster.n2'='192.168.0.2:8020',
'dfs.client.failover.proxy.provider.hacluster'='org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider',
'dfs.namenode.kerberos.principal'='hadoop/_HOST@REALM.COM'
'hadoop.security.authentication'='kerberos',
'hadoop.kerberos.principal'='doris_test@REALM.COM',
'hadoop.kerberos.keytab'='/path/to/doris_test.keytab'
);

-- 例子4：创建 Hive 集群中 hive_db 下的 hive_table 表, Hive数据存储在S3上
CREATE TABLE `t_hive` (
  `k1` int NOT NULL COMMENT "",
  `k2` char(10) NOT NULL COMMENT "",
  `k3` datetime NOT NULL COMMENT "",
  `k5` varchar(20) NOT NULL COMMENT "",
  `k6` double NOT NULL COMMENT ""
) ENGINE=HIVE
COMMENT "HIVE"
PROPERTIES (
'hive.metastore.uris' = 'thrift://192.168.0.1:9083',
'database' = 'hive_db',
'table' = 'hive_table',
'AWS_ACCESS_KEY' = 'your_access_key',
'AWS_SECRET_KEY' = 'your_secret_key',
'AWS_ENDPOINT' = 's3.us-east-1.amazonaws.com',
'AWS_REGION' = 'us-east-1'
);

参数说明：

外表列：
列名要于 Hive 表一一对应。
列的顺序需要与 Hive 表一致。
必须包含 Hive 表中的全部列。
Hive 表分区列无需指定，与普通列一样定义即可。
ENGINE 需要指定为 HIVE。
PROPERTIES 属性：
hive.metastore.uris：Hive Metastore 服务地址。
database：挂载 Hive 对应的数据库名。
table：挂载 Hive 对应的表名。
dfs.nameservices：name service名称，与 hdfs-site.xml 保持一致。
dfs.ha.namenodes.[nameservice ID]：namenode 的 ID 列表，与 hdfs-site.xml 保持一致。
dfs.namenode.rpc-address.[nameservice ID].[name node ID]：namenode 的 rpc 地址，数量与 namenode 数量相同，与 hdfs-site.xml 保持一致。
dfs.client.failover.proxy.provider.[nameservice ID] ：HDFS 客户端连接活跃 namenode 的 Java 类，通常是 org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider。
访问开启 Kerberos 的 Hive 数据源，需要为 Hive 外表额外配置如下 PROPERTIES 属性：
hadoop.security.authentication：认证方式请设置为 Kerberos，默认为 simple。
dfs.namenode.kerberos.principal：HDFS namenode 服务的 Kerberos 主体。
hadoop.kerberos.principal：设置 Doris 连接 HDFS 时使用的 Kerberos 主体。
hadoop.kerberos.keytab：设置 keytab 本地文件路径。
yarn.resourcemanager.principal： Doris链接Hadoop集群的resource mananger的Kerberos主体。
如果数据存储在类S3系统时，例如腾讯云 COS 等，需要配置下列属性：
AWS_ACCESS_KEY：腾讯云账户的 SecretId。
AWS_SECRET_KEY：腾讯云账户的 SecretKey。
AWS_ENDPOINT：COS 桶的 endpoint，例如：cos.ap-nanjing.myqcloud.com。
AWS_REGION：COS 桶的区域，例如：ap-nanjing。
注意
若要使 Doris 访问开启 Kerberos 认证方式的 Hadoop 集群，需要在 Doris 集群所有运行节点上部署 Kerberos 客户端 kinit，并配置 krb5.conf，填写 KDC 服务信息等。
PROPERTIES 属性 hadoop.kerberos.keytab 的值需要指定 keytab 本地文件的绝对路径，并允许 Doris 进程访问该本地文件。
关于 HDFS 集群的配置可以写入 hdfs-site.xml 文件中，该配置文件在 fe 和 be 的 conf 目录下，用户创建 Hive 表时，不需要再填写 HDFS 集群配置的相关信息。

类型匹配

支持的 Hive 列类型与 Doris 对应关系如下表：
Hive
Doris
描述
BOOLEAN
BOOLEAN

CHAR
CHAR
当前仅支持 UTF8编码
VARCHAR
VARCHAR
当前仅支持 UTF8编码
TINYINT
TINYINT

SMALLINT
SMALLINT

INT
INT

BIGINT
BIGINT

FLOAT
FLOAT

DOUBLE
DOUBLE

DECIMAL
DECIMAL

DATE
DATE

TIMESTAMP
DATETIME
Timestamp 转成 Datetime 会损失精度
注意
Hive 表 Schema 变更不会自动同步，需要在 Doris 中重建 Hive 外表。
当前 Hive 的存储格式仅支持 Text，Parquet 和 ORC 类型。
当前默认支持的 Hive 版本为 2.3.7、3.1.2，未在其他版本进行测试。后续后支持更多版本。

查询用法

完成在 Doris 中建立 Hive 外表后，除了无法使用 Doris 中的数据模型(rollup、预聚合、物化视图等)外，与普通的 Doris OLAP 表并无区别。
select * from t_hive where k1 > 1000 and k3 ='term' or k4 like '%doris';

中国站