Partage via

Fonction window_time

  • Article

S’applique à : coche marquée oui Databricks SQL coche pour oui Databricks Runtime 12.2 LTS et versions ultérieures

Retourne l’heure de fin inclusive d’une fenêtre de temps produite par la fonction window ou session_window.

Syntaxe

window_time(window)

Arguments

  • window : colonne window générée par la fonction window.

Retours

Valeur TIMESTAMP avec le point de terminaison inclusif de la fenêtre. Ceci équivaut à window.end - INTERVAL '0.000001' SECOND

Exemples

> SELECT a, window.start as start, window.end as end, window_time(window), cnt
    FROM (SELECT a, window, count(*) as cnt
           FROM VALUES ('A1', '2021-01-01 00:00:00'),
                       ('A1', '2021-01-01 00:04:30'),
                       ('A1', '2021-01-01 00:06:00'),
                       ('A2', '2021-01-01 00:01:00') AS tab(a, b)
           GROUP by a, window(b, '5 MINUTES'))
    ORDER BY a, window.start;
  A1  2021-01-01 00:00:00  2021-01-01 00:05:00  2021-01-01 00:04:59.999999 2
  A1  2021-01-01 00:05:00  2021-01-01 00:10:00  2021-01-01 00:09:59.999999 1
  A2  2021-01-01 00:00:00  2021-01-01 00:05:00  2021-01-01 00:04:59.999999 1