Hive表获取字段状态变化记录-Lag函数应用

场景：日志表中记录了关于某个实体的状态变化所有信息，想单单提取出，按照时间轴顺序，发生了状态变化的数据行；

思路：Lag函数或者Lead函数可以将上一行或者下一行的字段内容获取到本行，这样可以比较字段是否发生变化，进而判断是否状态变化，是否需要提取出该数据行；

实现SQL：

1. 数据行内容

select
house_id,
status,
create_time
from
tmp.tmp_test;

2. 实现想要的效果

select
t1.house_id,
t1.status,
t1.create_time
from
(
select
house_id,
status,
create_time,
lag(status,1,-999) over(partition by house_id order by create_time) as status2
from
tmp.tmp_test
) t1
where
t1.status <> t1.status2;