window_time-functie

  • Artikel

Van toepassing op:vinkje als ja aan Databricks SQL vinkje als ja aan Databricks Runtime 12.2 LTS en hoger

Retourneert de inclusieve eindtijd van een tijdvenster dat wordt geproduceerd door het venster of session_window functies.

Syntaxis

window_time(window)

Argumenten

  • window: Een window kolom die wordt gegenereerd door de vensterfunctie .

Retouren

Een TIMESTAMP waarde met het inclusieve eindpunt van het venster. Dit komt overeen met window.end - INTERVAL '0.000001' SECOND

Voorbeelden

> 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