LOCALTIMESTAMP as time_stamp

ts as case when time is null then CURRENT_TIMESTAMP else TO_TIMESTAMP_LTZ(time, 0) end ,
watermark for ts as ts - interval ‘60’ second
PARTITION BY 的都有回撤流
group by 的沒有回撤流 因為算的是指標
開窗又慢

SELECT *
FROM (SELECT *ROW_NUMBER() OVER (PARTITION BY id ORDER BY time_stamp) AS rnFROM eventsWHERE time_stamp >= NOW() - INTERVAL '7' DAY
) t
WHERE rn = 1;