hive的索引

发布于:2025-07-14 ⋅ 阅读:(17) ⋅ 点赞:(0)

一、索引的介绍

索引的作用:加快查询的效率

为什么索引可以提升查询效率呢?

二、hive的索引

         hive索引是在 分区 分桶优化基础上, 又提供一种新的优化手段, 如果分区 和分桶受限, 可以尝试使用索引的方式来优化处理

        hive提供了三种索引:

                原始索引

                row group index(行组索引)

                bloom filter index(布隆过滤索引)

1、hive的原始索引

​ 结论: 此索引已经不再使用, 在hive3.0以上, 彻底不支持

        hive的原始索引, 可以针对表中某一列或者某几列构建索引, 构建之后, 当查询的时候使用到索引字段, 可以帮助提升一定效率

弊端:

        hive原始索引, 不会自动更新, 每一次对表中数据进行处理后, 都需要进行重建索引, 而这个效率是比较差, 而且整体效率的提升,相对比较有限

 2、row group index(行组索引)

条件

        1) 要求表必须是ORC存储格式

        2) 需要对那个字段进行索引, 必须对这个字段进行排序, 否则索引意义不大

        3) 在创建表的时候, 必须开启行组索引: ’orc.create.index’=’true’

        4) 主要应用在 < > = 场景中, 主要针对数值类型数据

ORC是一种专为大数据优化的列存储格式,具有以下特点:

        1)高效压缩:按列存储相似数据,压缩率比行存储高 3-5 倍,节省存储空间。

        2)快速查询:内置多级索引(文件、stripe、行组),支持跳过无关数据,加速过滤和聚合。

        3)复杂类型支持:原生支持嵌套结构(如 JSON / 数组),适合半结构化数据。

        4)事务支持:结合 Hive 实现 ACID 事务(插入 / 更新 / 删除)。

        5)这就是orc存储格式

常用于 Hive、Spark 等框架,是数据仓库的主流存储格式,适合批量分析场景。

建表操作

CREATE TABLE lxw1234_orc2(

    ....

) stored AS ORC

TBLPROPERTIES

(

    'orc.compress'='SNAPPY',

--     开启行组索引

    'orc.create.index'='true'

)

stored AS ORC 指定使用 ORC(Optimized Row Columnar) 存储格式,这是一种高效的列存格式,适合大数据分析。

'orc.compress'='SNAPPY':启用 Snappy 压缩,在压缩率和性能间平衡,适合快速读写场景。

'orc.create.index'='true':开启 ORC 行组索引,记录每个行组的统计信息(如最小值、最大值),加速数据过滤。

插入数据

insert into table xxxx

    SELECT CAST(siteid AS INT) AS id,

    pcid

    FROM lxw1234_text

--     插入的数据保持排序

    DISTRIBUTE BY id sort BY id;

CAST(siteid AS INT) AS id 将 siteid 字段从字符串转为整数类型,并命名为 id

DISTRIBUTE BY id:按 id 的哈希值将数据分发到不同的 Reducer,确保相同 id 的记录被分到同一节点

3、bloom filter index(布隆过滤索引)

行组索引可以和布隆索引一起使用

条件

1) 必须是ORC类型的表

2) 需要按照哪一个字段进行等值连接, 就需要对这个字段构建布隆索引

3) 仅适合做等值连接, 不局限于数据类型

4) 在建表的时候, 必须指定为那些字段开启: ”orc.bloom.filter.columns”=”pcid,字段2..”

建表操作

CREATE TABLE lxw1234_orc2 (

   ....

) stored AS ORC

TBLPROPERTIES

(

    'orc.compress'='SNAPPY',

    'orc.create.index'='true',

--     pcid字段开启BloomFilter索引

    "orc.bloom.filter.columns"="pcid"

)

插入数据

insert into table xxxx

SELECT CAST(siteid AS INT) AS id,

pcid

FROM lxw1234_text

DISTRIBUTE BY id sort BY id;

使用索引

SET hive.optimize.index.filter=true --开启 hive的自动使用索引

SELECT COUNT(1) FROM lxw1234_orc1 WHERE id >= 0 AND id <= 1000   (行组索引)

AND pcid IN ('0005E26F0DCCDB56F9041C','A'); (布隆过滤索引)

注意 如果要使用hive的索引, 必须开启hive自动使用索引

SET hive.optimize.index.filter=true --开启 hive的自动使用索引  

当然也可以将这个配置, 直接配置到cm的hive的配置窗口中, 进行统一配置

在生产中这些索引如何选择呢?

1) 对于行组索引, 建议是常开即可

在插入数据, 如果不明确对那个字段使用行组索引, 可以任意的插入, 在条件合适情况下, 也在使用行组索引

2) 布隆过滤索引:  主要将那些用于 等值连接的字段开启索引即可

一般主要指的是 join关联字段 以及清洗字段


网站公告

今日签到

点亮在社区的每一天
去签到