blob: 8c86df8e1c2c0b9cf4198b91729567590609017b (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
/* syntax version 1 */
/* postgres can not */
SELECT
user,
ts,
payload,
AGGREGATE_LIST(ts) over w as ts_session,
COUNT(1) over w as session_len,
FROM plato.Input
WINDOW w AS (
PARTITION COMPACT BY user, SessionWindow(ts, 10)
ORDER BY ts
ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING
)
ORDER BY user, payload;
|