session_window تعبير التجميع

ينطبق على: Databricks SQL Databricks Runtime 10.4 LTS وما فوق

إنشاء نافذة جلسة عمل عبر تعبير الطابع الزمني.

بناء الجملة

session_window(expr, gapDuration)

الوسيطات

• exprTIMESTAMP: تعبير يحدد موضوع النافذة.
• gapDurationSTRING: تعبير يمثل عرض النافذة كحرفيةINTERVAL DAY TO SECOND.

المرتجعات

إرجاع مجموعة من التجميعات التي يمكن تشغيلها باستخدام دالات تجميعية. GROUP BY اسم العمود هو session_window. ومن نوع STRUCT<start:TIMESTAMP, end:TIMESTAMP>

الأمثلة

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

> SELECT a, session_window.start, session_window.end, count(*) as cnt
    FROM VALUES ('A1', '2021-01-01 00:00:00'),
                ('A1', '2021-01-01 00:04:30'),
                ('A1', '2021-01-01 00:10:00'),
                ('A2', '2021-01-01 00:01:00'),
                ('A2', '2021-01-01 00:04:30') AS tab(a, b)
    GROUP by a, session_window(b, CASE WHEN a = 'A1' THEN '5 minutes'
                                       WHEN a = 'A2' THEN '1 minute'
                                       ELSE '10 minutes' END)
    ORDER BY a, start;
  A1  2021-01-01 00:00:00  2021-01-01 00:09:30  2
  A1  2021-01-01 00:10:00  2021-01-01 00:15:00  1
  A2  2021-01-01 00:01:00  2021-01-01 00:02:00  1
  A2  2021-01-01 00:04:30  2021-01-01 00:05:30  1

الدالات ذات الصلة

• تعبير تجميع النوافذ
• الدالة window_time