共用方式為

window 群組運算式

  • 發行項

適用于：核取標示為是 Databricks SQL 檢查標示為是 Databricks Runtime

在時間戳記運算式上建立以跳動為基礎的滑動視窗。

語法

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

參數

  • expr：指定視窗主旨的 TIMESTAMP 運算式。
  • width：STRING 常值，代表視窗的寬度為 INTERVAL DAY TO SECOND 常值。
  • start：選擇性的 STRING 常值，代表以 INTERVAL DAY TO SECOND 常值表示的下一個視窗開頭。
  • slide：選擇性的 STRING 常值，代表從午夜開始的位移，以 INTERVAL HOUR TO SECOND 常值表示。

返回

傳回一組可透過彙總函式操作的群組。 GROUP BY 資料行名稱為 window 。 其類型為 STRUCT<start:TIMESTAMP, end:TIMESTAMP>

slide 必須小於或等於 width 。 start 必須小於 slide 。

如果 slide<width 每個群組中的資料列重迭。 根據預設 slide ， width 等於 ，因此 expr 會分割成群組。 視窗從 開始 1970-01-01 00:00:00 UTC + start 。 的 start 預設值為 '0 SECONDS' '

例子

> 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