Hive 刷题——会话划分问题

需求描述 

现有页面浏览记录表（page_view_events）如下，表中有每个用户的每次页面访问记录。

规定若同一用户的相邻两次访问记录时间间隔小于60s，则认为两次浏览记录属于同一会话。现有如下需求，为属于同一会话的访问记录增加一个相同的会话id字段，会话id格式为"user_id-number"，其中number从1开始，用于区分同一用户的不同会话，期望结果如下：

参考实现 

select user_id,page_id,view_timestamp,concat(user_id,'-',flag)session_id
from (select user_id, page_id,view_timestamp, sum(flag) over (partition by user_id order by view_timestamp) flag
      from (select user_id, page_id, view_timestamp, if(view_timestamp - last_view_timestamp > 60, 1, 0) flag --打标签，本次page的时间戳减去上个页面的时间戳，如果大于60秒，证明本次page是会话的初始page，打上一
            from (select user_id,
                         page_id,
                         view_timestamp,
                         lag(view_timestamp, 1, 0)
                             over (partition by user_id order by view_timestamp) last_view_timestamp --取出上一个page页面的时间戳
                  from page_view_events) t) t) t;