Fungsi windowing

✅ Azure Stream Analytics ✅ Fabric Eventstream

Dalam aplikasi yang memproses peristiwa real-time, adalah umum untuk melakukan beberapa komputasi berbasis set (agregasi) atau operasi lain atas subset peristiwa yang termasuk dalam beberapa periode waktu. Karena konsep waktu adalah kebutuhan mendasar untuk sistem pemrosesan peristiwa yang kompleks, penting untuk memiliki cara sederhana untuk bekerja dengan komponen waktu logika kueri dalam sistem. Di Azure Stream Analytics, subset peristiwa ini didefinisikan melalui jendela untuk mewakili pengelompokan menurut waktu. Artikel ini menjelaskan jendela dan bagaimana jendela didefinisikan, mengidentifikasi jenis jendela yang didukung, dan menjelaskan bagaimana Anda dapat menggunakan jendela dengan berbagai operator.

Memahami Windows

Jendela berisi data peristiwa di sepanjang garis waktu dan memungkinkan Anda melakukan berbagai operasi terhadap peristiwa di dalam jendela tersebut. Misalnya, Anda mungkin ingin menjumlahkan nilai bidang payload di jendela tertentu seperti yang diperlihatkan dalam ilustrasi berikut.

Setiap operasi jendela menghasilkan peristiwa di akhir jendela. Jendela Azure Stream Analytics dibuka pada waktu mulai jendela dan ditutup pada waktu akhir jendela. Misalnya, jika Anda memiliki jendela 5 menit dari pukul 12.00 hingga 12.05, semua peristiwa dengan tanda waktu lebih besar dari pukul 12.00 dan hingga tanda waktu 12.05 inklusif akan disertakan dalam jendela ini. Output jendela akan menjadi satu peristiwa berdasarkan fungsi agregat yang digunakan dengan tanda waktu yang sama dengan waktu akhir jendela. Tanda waktu peristiwa output jendela dapat diproyeksikan dalam pernyataan SELECT menggunakan properti System.Timestamp() menggunakan alias. Setiap jendela secara otomatis menyelaraskan dirinya ke jam ke-nol. Misalnya, jendela tumbling 5 menit akan menyelaraskan dirinya dengan (12:00-12:05] , (12:05-12:10], ..., dan sebagainya.

Setelah operasi jendela, tanda waktu peristiwa akan berbeda dari atribut waktu peristiwa asli (baik waktu kedatangan atau kolom yang digunakan dengan TIMESTAMP BY). Tanda waktu peristiwa yang diperbarui saat ini selalu dapat diakses dengan system.timestamp().

Nota

Semua jendela harus digunakan dalam klausa GROUP BY.

Ada lima jenis jendela:

1. Jendela Tumbling

2. Jendela Lompat

3. Jendela Geser

4. Jendela Sesi

5. Jendela Rekam Jepret

Ukuran maksimum jendela dalam semua kasus adalah 7 hari.

Anda dapat mengagregasi beberapa jendela waktu dalam pernyataan GROUP BY yang sama menggunakan fungsi Windows .

Lihat Juga

Fungsi Bawaan
Fungsi Agregat
Fungsi Analitik
Fungsi Array (Analisis Aliran)
Fungsi Konversi
Fungsi Tanggal dan Waktu
Fungsi Rekaman