hive不支援update語句，但我們可以通過增加一個變更表來間接實現update功能。

假設我們有一張user表，對user表的更新都作為新記錄插入到user_delta表中，每條插入都有插入時間欄位updated。獲取最新的user資訊：

SELECT
  COALESCE(b.`id`, a.`id`) AS `id`  --COALESCE是返回首個不為空的表示式
  ,COALESCE(b.`name`, a.`name`) AS `name`
  ,COALESCE(b.`age`, a.`age`) AS `age`
  ,COALESCE(b.`updated`, a.`updated`
 
) AS `updated`
FROM dw_stage.`user` a
FULL OUTER JOIN (
  -- 增量資料會包含重複資料，因此需要選擇最新的那一條
  SELECT `id`, `name`, `age`, `updated`
  FROM (
    SELECT *, ROW_NUMBER() OVER (PARTITION BY `id` ORDER BY `updated` DESC) AS `n`
    FROM dw_stage.`user_delta`
  ) b
  WHERE `n` = 1
) b
ON a.`id` = b.`id`;

mysql中不支援ROW_NUMBER() OVER (PARTITION BY）分窗語句，可以用如下方式實現相同功能：

set @time_rank=0;
set @current_CustomerID=Null;
​
select * from (
SELECT *, 
@time_rank:=if(@current_CustomerID = CustomerID, @time_rank + 1, 1) as num, 
@current_CustomerID := CustomerID 
from OrderInfo 
ORDER BY CustomerID, CreateTime desc 
) tmp 
where num = 1;

這樣會取出每個CustomerID最新CreateTime的記錄。
然後就可以用聯查獲取最新資料了。