Atlama Penceresi

✅ Azure Stream Analytics ✅ Fabric Olay Akışı

Atlayan pencerelerden farklı olarak, atlamalı pencereler modeli çakışan pencereler zamanlanmış. Atlamalı pencere belirtimi üç parametreden oluşur: zaman birimi, windowsize (her pencerenin ne kadar sürdüğü) ve atlama (her pencerenin öncekine göre ne kadar ileri doğru ilerlediği). Ayrıca , offsetsize isteğe bağlı bir dördüncü parametre olarak kullanılabilir. Yuvarlanan pencerenin yalnızca 'atlama' değeri 'boyutuna' eşit olan bir atlamalı pencere olduğunu unutmayın.

Aşağıdaki çizimde bir dizi olay içeren bir akış gösterilmektedir. Her kutu, bir atlama penceresini ve 'atlama' öğesinin 5 ve 'boyut' 10 olduğu varsayılarak bu pencerenin parçası olarak sayılan olayları temsil eder.

Sözdizimi

{HOPPINGWINDOW | HOPPING} ( timeunit  , windowsize , hopsize, [offsetsize] )
{HOPPINGWINDOW | HOPPING} ( Duration( timeunit  , windowsize ) , Hop (timeunit  , windowsize ), [Offset(timeunit  , offsetsize)])  
  

Uyarı

Atlama Penceresi yukarıdaki iki şekilde kullanılabilir. Windowsize ve hopsize aynı zaman birimine sahipse, Bunu Süre ve Atlama işlevleri olmadan kullanabilirsiniz. Süre işlevi, pencere boyutunu belirtmek için diğer pencere türleriyle de kullanılabilir.

Tartışmalar

zaman birimi

Pencere veyaatlama için zaman birimidir. Aşağıdaki tabloda tüm geçerli zaman birimi bağımsız değişkenleri listelemektedir.

Zaman Birimi	Kısaltmalar
gün	dd, d
saat	Hh
dakika	mi, n
saniye	ss, s
milisaniye	Ms
Microsecond	Mcs

windowsize

Pencerenin boyutunu açıklayan büyük bir tamsayı. Windowsize statiktir ve çalışma zamanında dinamik olarak değiştirilemez.

Her durumda pencerenin en büyük boyutu 7 gündür.

atlama

Atlamanın boyutunu açıklayan büyük bir tamsayı.

offsetsize

Varsayılan olarak, atlama pencereleri pencerenin sonunda kapsayıcıdır ve başlangıçta özeldir; örneğin 12:05 – 13:05 penceresi tam olarak 13:05'te gerçekleşen olayları içerir, ancak 12:05:05'te gerçekleşen olayları içermez (bu olay 23:00 – 13:00 penceresinin parçası olacaktır).
Offset parametresi, davranışı değiştirmek ve olayları pencerenin başına dahil etmek ve sonunda gerçekleşenleri dışlamak için kullanılabilir.

Örnekler

SELECT System.Timestamp() AS WindowEnd, TollId, COUNT(*)  
FROM Input TIMESTAMP BY EntryTime  
GROUP BY TollId, HoppingWindow(Duration(hour, 1), Hop(minute, 5), Offset(millisecond, -1))  
  

Zaman konusunda dikkat edilmesi gerekenler

Her pencere işlemi, pencerenin sonunda olay çıkışı oluşturur (atlama pencereleri söz konusu olduğunda, bu her atlama boyutunda gerçekleşir). Azure Stream Analytics pencereleri, pencere başlangıç zamanında açılır ve pencere bitiş saatinde kapatılır. Örneğin, saat 12:00 ile 12:05 arasında 5 dakikalık bir pencereniz varsa, zaman damgası 12:00'den büyük olan ve 12:05'e kadar (dahil) zaman damgasına sahip tüm olaylar bu pencereye eklenir. Pencerenin çıkışı, pencere bitiş zamanına eşit bir zaman damgası ile kullanılan toplama işlevini temel alan tek bir olay olacaktır. Pencerenin çıkış olayının zaman damgası, system.timestamp() özelliği kullanılarak select deyiminde diğer ad kullanılarak yansıtılabilir.