Přeskakující okno

✅Eventstream prostředků infrastruktury Azure Stream Analytics ✅

Přeskakující okna jsou řada nepřekrývajících se a souvislých časových intervalů s pevnou velikostí. Následující diagram znázorňuje datový proud s řadou událostí a jejich mapování na 10sekundová přeskakující okna.

Syntaxe

{TUMBLINGWINDOW | TUMBLING} ( timeunit  , windowsize, [offsetsize] )  
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit  , windowsize ), [Offset(timeunit  , offsetsize)] )  
  

Poznámka:

Přeskakující okno lze použít výše dvěma způsoby. Chcete-li povolit konzistenci s oknem Skákání, lze funkci Doba trvání použít také se všemi typy oken k určení velikosti okna. Doba trvání okna musí být kladná plovoucí konstanta.

Argumenty

timeunit

Je jednotkou času pro časové období. V následující tabulce jsou uvedeny všechny platné argumenty časového limitu.

Timeunit	Zkratky
den	dd, d
hodina	Hh
minuta	mi, n
vteřina	ss, s
milisekunda	milisekunda
mikrosekunda	Mcs

windowsize

Velké celé číslo, které popisuje velikost okna. Windowsize je statická a nelze ji dynamicky měnit za běhu.

Maximální velikost okna je 7 dní.

offsetsize

Ve výchozím nastavení jsou přeskakující okna inkluzivní na konci okna a exkluzivní na začátku – například 12:00 – 13:00 – 13:00 okno bude obsahovat události, které proběhly přesně v 13:00, ale nebudou zahrnovat události, ke kterým došlo v 12:00 (tyto události budou součástí 11:00–12:00 pm window).

Parametr Posun lze použít ke změně tohoto chování a zahrnutí událostí na začátku okna a vyloučení událostí, ke kterým došlo na konci.

Příklady

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

SELECT 'reset' AS command
INTO
    alert
FROM
    temperature TIMESTAMP BY timeCreated
GROUP BY TumblingWindow(second,15)
HAVING Avg(machine.temperature) > 25

Důležité informace o čase

Každá operace okna vypíše událost na konci okna. Okna Služby Azure Stream Analytics se otevřou v počátečním čase okna a zavře se v době ukončení okna. Pokud máte například 5minutové okno od 12:00 do 12:05 do 12:05 a všechny události s časovým razítkem delším než 12:00 a až do časového razítka 12:05 včetně budou zahrnuty v tomto okně. Výstupem okna bude jedna událost založená na agregační funkci použité s časovým razítkem, které se rovná koncovému času okna. Časové razítko výstupní události okna lze projektovat v příkazu SELECT pomocí vlastnosti System.Timestamp() pomocí aliasu.

Viz také

Skákání okna
Posuvné okno
Okenní zobrazení