Freigeben über

window-Gruppierungsausdruck

Gilt für:durch Häkchen mit „Ja“ markiert Databricks SQL durch Häkchen mit „Ja“ markiert Databricks Runtime

Erstellt ein Hopping-basiertes gleitendes Fenster über einen TIMESTAMP-Ausdruck.

Syntax

window(expr, width [, slide [, start] ] )

Argumente

  • expr: Ein TIMESTAMP-Ausdruck, der den Betreff des Fensters angibt.
  • width: Ein STRING-Literal, der die Breite des Fensters als INTERVAL DAY TO SECOND-Literal darstellt.
  • slide: Ein optionales STRING-Literal, das einen Offset von Mitternacht bis Anfang darstellt, ausgedrückt als INTERVAL HOUR TO SECOND-Literal.
  • start: Ein optionales STRING-Literal, das den Anfang des nächsten Fensters darstellt, ausgedrückt als INTERVAL DAY TO SECOND-Literal.

Gibt zurück

Gibt einen Satz von Gruppierungen zurück, die mit Aggregatfunktionen verarbeitet werden können. Der GROUP BY-Spaltenname lautet window. Er ist vom Typ STRUCT<start TIMESTAMP, end TIMESTAMP>.

slide muss kleiner als oder gleich width sein. start muss kleiner als slide sein.

Wenn slide<width, überlappen sich die Zeilen in den einzelnen Gruppen. slide ist standardmäßig gleich width. expr werden also in Gruppen partitioniert. Das Windowing beginnt bei 1970-01-01 00:00:00 UTC + start. Der Standardwert start lautet '0 SECONDS'"

Beispiele

> 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
  • Last updated on