前言
Hive的分區(qū)和分桶都是細(xì)化數(shù)據(jù)管理,加快數(shù)據(jù)查詢和分析,兩者有什么區(qū)別呢?下面講解一下分區(qū)和分桶的原理。
分區(qū)及原理
Hive的分區(qū)表可以有一個(gè)或多個(gè)分區(qū)鍵,用于確定數(shù)據(jù)的存儲(chǔ)方式。分區(qū)(除了作為存儲(chǔ)單元)還允許用戶有效地識(shí)別滿足指定條件的數(shù)據(jù),顯著加快查詢分析速度。分區(qū)字段并不是數(shù)據(jù)的一部分,而是加載時(shí)虛擬的列,數(shù)據(jù)在HDFS上存儲(chǔ)時(shí)分區(qū)就相當(dāng)于文件目錄。
分區(qū)建表SQL
分區(qū)表使用partitioned by 子句指定,以指定字段列,需要指定字段類型。
--分區(qū)表建表sql
USE testdb;
CREATE TABLE test_partition (
field1 String Comment 'field1 comment',
field2 String Comment 'field2 comment')
Comment 'table comment'
PARTITIONED BY(d String Comment 'date')
STORED AS ORC;
--分區(qū)表查詢
SELECT *
FROM testdb.test_partition
WHERE d = '2022-02-01'
建表完成后查看LOCATION參數(shù)為:'
hdfs://ns/user/hive/warehouse/testdb.db/test_partition'。當(dāng)存儲(chǔ)數(shù)據(jù)時(shí),2022-02-01日期的數(shù)存儲(chǔ)在hdfs://ns/user/hive/warehouse/testdb.db/test_partition/d=2022-02-01目錄下。
如果指定多個(gè)分區(qū)列用逗號(hào)分隔開,如:建表是PARTITIONED BY(d String Comment 'date',h String Comment 'hour'),分區(qū)字段日期常用格式:d=yyyy-MM-dd,h=HH。第二個(gè)參數(shù)會(huì)作為子目錄存儲(chǔ)在HDFS上:***/test_partition/d=2022-02-01/h=12
分桶及原理
分桶表中的數(shù)據(jù)可以根據(jù)表中某列的哈希函數(shù)的值依次劃分為存儲(chǔ)桶,用于分桶的字段是數(shù)據(jù)中實(shí)際的一列。其原理:根據(jù)分桶的列計(jì)算hash值,對(duì)hash值取模運(yùn)算,將數(shù)據(jù)放到對(duì)應(yīng)的桶里。
分桶建表SQL
分桶表由clustered by 子句指定,指定字段為真實(shí)字段,需要指定桶的個(gè)數(shù),桶編號(hào)從零開始。
--分桶表建表sql,創(chuàng)建4個(gè)桶
USE testdb;
CREATE TABLE test_bucket (
field1 String Comment 'field1 comment',
field2 String Comment 'field2 comment')
COMMENT 'table comment'
clustered by (field1) into 4 buckets
row format delimited
fields terminated by ',';
--分桶表查詢
SELECT *
FROM testdb.test_bucket
WHERE field1 = '0'
相同點(diǎn)和不同點(diǎn)
相同點(diǎn):分區(qū)和分桶表都是Hive細(xì)化數(shù)據(jù)管理,加快數(shù)據(jù)查詢和分析。
不同點(diǎn):
- 分區(qū)字段不是實(shí)際的列,分桶字段必須是實(shí)際的列。
- 分區(qū)表的分區(qū)數(shù)量可以一直增長(zhǎng),而分桶表創(chuàng)建好后桶的數(shù)量就固定不變了。
思考
因?yàn)榉滞霸硎怯胔ash計(jì)算后取模計(jì)算分桶,用哈希計(jì)算必然會(huì)沖突,如果大批量數(shù)據(jù)計(jì)算的hash值相等,極端情況下全部數(shù)據(jù)集中到一個(gè)桶中時(shí),就導(dǎo)致分桶表退化成一張維表。






