window
expressão de agrupamento
Aplica-se a: Databricks SQL Databricks Runtime
Cria uma janela deslizante baseada em saltos sobre uma expressão de carimbo de data/hora.
Sintaxe
window(expr, width [, slide [, start] ] )
Argumentos
expr
: uma expressão TIMESTAMP que especifica o assunto da janela.width
: um literal DE CADEIA que representa a largura da janela como um literal INTERVAL DAY TO SECOND.start
: um literal de CADEIA opcional que representa o início da janela seguinte expresso como um literal INTERVAL DAY TO SECOND.slide
: um literal de CADEIA opcional que representa um desvio da meia-noite para o início, expresso como um literal INTERVAL HOUR TO SECOND.
Devoluções
Devolve um conjunto de agrupamentos que podem ser operados com funções de agregação.
O nome da coluna GROUP BY é window
. É do tipo STRUCT<start:TIMESTAMP, end:TIMESTAMP>
slide
tem de ser menor ou igual a width
.
start
tem de ser menor que slide
.
Se slide
<width
as linhas em cada grupos se sobrepõem.
Por predefinição slide
, é width
expr
igual a particionado em grupos.
A janela começa em 1970-01-01 00:00:00 UTC + start
. A predefinição para start
é '0 SECONDS'
"
Exemplos
> SELECT window, min(val), max(val), count(val)
FROM VALUES (TIMESTAMP'2020-08-01 12:20:21', 17),
(TIMESTAMP'2020-08-01 12:20:22', 12),
(TIMESTAMP'2020-08-01 12:23:10', 8),
(TIMESTAMP'2020-08-01 12:25:05', 11),
(TIMESTAMP'2020-08-01 12:28:59', 15),
(TIMESTAMP'2020-08-01 12:30:01', 23),
(TIMESTAMP'2020-08-01 12:30:15', 2),
(TIMESTAMP'2020-08-01 12:35:22', 16) AS S(stamp, val)
GROUP BY window(stamp, '2 MINUTES 30 SECONDS', '30 SECONDS', '15 SECONDS');
{2020-08-01 12:19:15, 2020-08-01 12:21:45} 12 17 2
{2020-08-01 12:18:15, 2020-08-01 12:20:45} 12 17 2
{2020-08-01 12:20:15, 2020-08-01 12:22:45} 12 17 2
{2020-08-01 12:19:45, 2020-08-01 12:22:15} 12 17 2
{2020-08-01 12:18:45, 2020-08-01 12:21:15} 12 17 2
{2020-08-01 12:21:45, 2020-08-01 12:24:15} 8 8 1
{2020-08-01 12:22:45, 2020-08-01 12:25:15} 8 11 2
{2020-08-01 12:21:15, 2020-08-01 12:23:45} 8 8 1
{2020-08-01 12:22:15, 2020-08-01 12:24:45} 8 8 1
{2020-08-01 12:20:45, 2020-08-01 12:23:15} 8 8 1
{2020-08-01 12:23:45, 2020-08-01 12:26:15} 11 11 1
{2020-08-01 12:23:15, 2020-08-01 12:25:45} 11 11 1
{2020-08-01 12:24:45, 2020-08-01 12:27:15} 11 11 1
{2020-08-01 12:24:15, 2020-08-01 12:26:45} 11 11 1
{2020-08-01 12:27:15, 2020-08-01 12:29:45} 15 15 1
{2020-08-01 12:27:45, 2020-08-01 12:30:15} 15 23 2
{2020-08-01 12:28:45, 2020-08-01 12:31:15} 2 23 3
{2020-08-01 12:26:45, 2020-08-01 12:29:15} 15 15 1
{2020-08-01 12:28:15, 2020-08-01 12:30:45} 2 23 3
{2020-08-01 12:29:45, 2020-08-01 12:32:15} 2 23 2