| drop table over10k_n16; |
| |
| create table over10k_n16( |
| t tinyint, |
| si smallint, |
| i int, |
| b bigint, |
| f float, |
| d double, |
| bo boolean, |
| s string, |
| ts timestamp, |
| `dec` decimal, |
| bin binary) |
| row format delimited |
| fields terminated by '|'; |
| |
| load data local inpath '../../data/files/over10k' into table over10k_n16; |
| |
| -- sum |
| select ts, f, sum(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, sum(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, sum(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, sum(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |
| |
| -- avg |
| select ts, f, avg(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, avg(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, avg(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, avg(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |
| |
| -- count |
| select ts, f, count(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, count(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, count(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, count(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |
| |
| -- max |
| select ts, f, max(f) over (partition by ts order by t,f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, max(f) over (partition by ts order by t,f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, max(f) over (partition by ts order by t,f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, max(f) over (partition by ts order by t,f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |
| |
| -- min |
| select ts, f, min(f) over (partition by ts order by t,f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, min(f) over (partition by ts order by t,f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, min(f) over (partition by ts order by t,f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, min(f) over (partition by ts order by t,f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |
| |
| -- first_value |
| select ts, f, first_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, first_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |
| |
| -- last_value |
| select ts, f, last_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k_n16 limit 100; |
| select ts, f, last_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k_n16 limit 100; |
| select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k_n16 limit 100; |