ハイブで不等式条件を持つ内部クエリを使用する方法

Question

私は、外部クエリに依存する不等式条件を持つ内部クエリを持つ次のクエリを持っています。 HIVEは、内部クエリからの外部クエリを不等式条件で参照することをサポートしていないようです。この質問をHIVEに書くにはどうすればいいですか？

SELECT 
* 
FROM  
A 
WHERE NOT EXISTS 
(
SELECT * 
FROM 
    B 
WHERE 
    B.cust_id = A.cust_id 
    AND datediff(A.year_month, B.year_month) < 365 * 3 
) 

Answer 1

使用している機能はHiveではサポートされていません。クエリを書き換えることは可能です：

SELECT * 
    FROM A 
     LEFT JOIN B ON B.cust_id = A.cust_id 
    WHERE (datediff(A.year_month, B.year_month) >= 365 * 3) --note >= here 
     OR B.cust_id is NULL --is not joined 

Answer 2

Will Hiveはこのクエリを受け入れますか？

SELECT ab.* 
FROM (SELECT a.*, b.min_year_month 
     FROM a JOIN 
      (SELECT b.cust_id, MAX(b.year_month) as min_year_month 
      FROM b 
      GROUP BY b.cust_id 
      ) b 
      ON a.cust_id = b.cust_id 
    ) ab 
WHERE datediff(A.year_month, B.min_year_month) < 365 * 3; 

論理が正しいと思います。これにより、Bのすべてのレコードが過去3年間のものであるAのすべてのレコードが返されます。

重要なアイデアは、集計とサブクエリを使用して必要なデータを取得することです。

実際にレコードをBにも記録したい場合は、別のJOINを使用してレコードを取得してください。