自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

你知道Hive統(tǒng)計函數(shù)count(*)為什么不走MR嗎?

數(shù)據(jù)庫 其他數(shù)據(jù)庫
用insert into 的方式插入到Hive表數(shù)據(jù)時,元數(shù)據(jù)會記錄插入的數(shù)量,為了優(yōu)化查詢,無條件count(*)查詢時直接查元數(shù)據(jù)中記錄的numRows字段,導致結果不準確。

問題

Hive執(zhí)行count(*)不走MR呢?

先說結論:如果表數(shù)據(jù)是insert進表的,count(*)統(tǒng)計時,帶where條件執(zhí)行時候Hive會執(zhí)行MR,如果不帶where條件,Hive會從元數(shù)據(jù)庫表metastore.TABLE_PARAMS中直接獲取numRows字段的值獲取記錄數(shù)。下面創(chuàng)建表進行驗證,在驗證時發(fā)現(xiàn)了Hive在無條件count(*)統(tǒng)計中的一個bug,bug現(xiàn)象也會下面驗證。

創(chuàng)建測試表

create database testdb;
use testdb;
--測試hive
create table test(
id int comment 'id'
)comment '測試hive'
insert into test values('1001');
select count(*) from test ;
select count(*) from test where id>=1001;

hive表存儲位置

表描述信息

hdfs上生成了數(shù)據(jù)

數(shù)據(jù)內容

從上面兩個圖上可以看到建表后插入一條記錄,會在metastore.TABLE_PARAMS 表中記錄該表的信息,并且用numRows記錄該表的數(shù)量,查看HDFS該表所在的路徑生成了000000_0的文件,下載下來查看確實是1001。

執(zhí)行count(*)

不帶where條件執(zhí)行:查詢非??欤膊]有走MR。

不帶where條件執(zhí)行結果

帶where條件執(zhí)行:查詢比較慢,且走了MR。

可以驗證Hive不帶where條件的執(zhí)行不走MR,而是直接從元數(shù)據(jù)里獲取表的行數(shù),這也算是一種優(yōu)化,畢竟Hive存儲的數(shù)據(jù)大多是T+1的數(shù)據(jù),數(shù)據(jù)寫入后一般不會改變。

Hive的一個bug

本地創(chuàng)建一個ids.txt文件,通過hadoop fs -put 命令上傳到表映射路徑/user/hive/warehouse/testdb.db/test上。

創(chuàng)建文件并上傳到表路徑。

hdfs文件下載并查看結果

執(zhí)行不帶where條件的count(*)結果就是錯誤的,而帶where條件的是正確的。

然后通過Hive執(zhí)行帶條件和不帶條件的查詢結果發(fā)現(xiàn),不帶where條件中的查詢結果是1,而帶where條件的結果是3,說明直接通過hadoop fs -put把文件上傳到路徑的方式會導致Hive在沒有條件的統(tǒng)計下結果是錯誤的,也側面證明了無條件的count(*)是從元數(shù)據(jù)庫直接取的數(shù)據(jù),而用select * 查詢時結果卻是正確的。

解決方法

要解決上面問題,可以使用Load data指令導入數(shù)據(jù),但是有如下幾點要注意:

  • 有LOCAL表示從本地文件系統(tǒng)加載,文件會被拷貝到HDFS中。
  • 無LOCAL表示從HDFS中加載數(shù)據(jù),文件直接被移動,而不是拷貝。
  • OVERWRITE 表示是否覆蓋表中數(shù)據(jù)(或指定分區(qū)的數(shù)據(jù)),沒有OVERWRITE 會直接APPEND,而不會濾重。
  • 如果加載同樣文件名的文件,會被自動重命名。

load data

用load data指令上傳完數(shù)據(jù)后,再次用無條件的count(*)統(tǒng)計結果,發(fā)現(xiàn)Hive又走了MR統(tǒng)計,并且結果是正確的。

總結

用insert into 的方式插入到Hive表數(shù)據(jù)時,元數(shù)據(jù)會記錄插入的數(shù)量,為了優(yōu)化查詢,無條件count(*)查詢時直接查元數(shù)據(jù)中記錄的numRows字段,導致結果不準確。

責任編輯:姜華 來源: 今日頭條
相關推薦

2024-04-03 09:23:31

ES索引分析器

2020-11-17 08:30:06

LinuxSwapping 設計

2023-11-02 10:22:29

gRPC后端通信

2024-10-09 08:19:35

2024-01-09 07:29:05

Argo代碼庫應用程序

2020-04-16 11:19:55

深度學習神經(jīng)網(wǎng)絡網(wǎng)絡層

2024-10-12 14:58:07

2023-06-26 08:20:02

openapi格式注解

2023-03-09 08:23:07

序列化?接口方法

2023-09-08 08:35:42

層疊樣式表CSS

2021-02-20 08:21:18

Hive動態(tài)分區(qū)

2023-08-30 07:27:39

2018-10-28 15:40:23

Python編程語言

2022-09-28 18:16:34

JavaJDK

2020-04-01 17:50:02

Python編程語言

2014-07-15 11:05:30

黑莓

2023-12-20 08:23:53

NIO組件非阻塞

2024-04-30 09:02:48

2015-12-01 13:33:51

UnikernelLinux運維

2021-11-12 05:59:23

容災備份5G
點贊
收藏

51CTO技術棧公眾號