基于Presto实现按cust_id聚合取最新地址信息并计算总天数

云上老周

2026-8-6

解决方案：Presto SQL实现分组取最新记录并计算全局总天数

针对你的需求，这里提供符合Presto语法的SQL实现，核心通过窗口函数完成分组取最新记录、全局日期差求和的双重目标：

WITH customer_latest_records AS (
    SELECT 
        cust_id,
        street_id,
        hood_id,
        city_id,
        -- 按cust_id分组，给每组记录按时间降序编号，rn=1即为最新记录
        ROW_NUMBER() OVER (PARTITION BY cust_id ORDER BY start_date DESC) AS record_rank,
        -- 计算所有记录的(end_date - start_date)总和，全局生效
        SUM(end_date - start_date) OVER () AS total_days
    FROM customers
)
SELECT 
    cust_id,
    street_id,
    hood_id,
    city_id,
    total_days
FROM customer_latest_records
WHERE record_rank = 1;

关键细节说明：

若判断“最新记录”的依据是end_date而非start_date，只需将ORDER BY start_date DESC替换为ORDER BY end_date DESC即可；
SUM(end_date - start_date) OVER ()的空窗口范围（OVER ()）表示计算全表的日期差总和，确保每个分组的最新记录都能携带全局的total_days值；
若存在同一cust_id下多条时间完全相同的“最新记录”，ROW_NUMBER()会随机保留一条，如需保留所有同时间的最新记录，可改用RANK()或DENSE_RANK()。