hive row_number()函数与子查询联用的方法

作者:袖梨 2026-06-17

在Hive中,您可以使用窗口函数row_number()与子查询联用以对结果集进行排序和分区

hive row_number()如何与子查询联用

假设您有一个名为sales_data的表,其中包含以下列:id(订单ID),product_id(产品ID)和amount(销售额)。您想要根据amount降序排列并计算每个产品的累积销售额。您可以使用以下查询实现这一目标:

SELECTid,product_id,amount,SUM(amount) OVER (PARTITION BY product_id ORDER BY amount DESC) as cumulative_salesFROM (SELECTid,product_id,amount,ROW_NUMBER() OVER (ORDER BY amount DESC) as row_numFROMsales_data) subqueryWHEREsubquery.row_num <= 1;

在这个查询中,我们首先使用子查询(别名为subquery)来计算每个订单的row_number(),根据amount降序排列。然后,在外部查询中,我们使用窗口函数SUM()计算每个产品的累积销售额,将结果集按照product_id进行分区。最后,我们在WHERE子句中过滤出累积销售额最高的产品。

相关文章

精彩推荐