Skjutfönster (Azure Stream Analytics)

När du använder ett skjutfönster uppmanas systemet att logiskt överväga alla möjliga fönster med en viss längd. Eftersom antalet sådana fönster skulle vara oändligt matar Azure Stream Analytics i stället ut händelser endast för de tidpunkter då innehållet i fönstret faktiskt ändras, med andra ord när en händelse har angetts eller lämnar fönstret.

Följande diagram illustrerar en ström med en serie händelser och hur de mappas till skjutfönster på 10 sekunder.

Syntax

{SLIDINGWINDOW | SLIDING} ( timeunit, windowsize )
{SLIDINGWINDOW | SLIDING} ( Duration( timeunit, windowsize ) )

Anteckning

Skjutfönstret kan användas på de två sätten ovan. För att tillåta konsekvens med hoppningsfönstret kan funktionen Varaktighet också användas med alla typer av fönster för att ange fönsterstorleken.

Argument

timeunit

Är tidsenheten för windowsize. I följande tabell visas alla giltiga timeunit-argument.

Tidsenhet	Förkortningar
day	dd, d
timme	hh
minut	mi, n
sekund	ss, s
Millisekund	Ms
mikrosekunder	Mcs

windowsize

Ett stort heltal som beskriver fönstrets storlek. Windows-storleken är statisk och kan inte ändras dynamiskt vid körning.

Fönstrets maximala storlek är i samtliga fall 7 dagar.

Exempel

Det här exemplet hittar alla avgiftsbelagda bås som har betjänat fler än 3 fordon under de senaste 5 minuterna:

SELECT DateAdd(minute,-5,System.Timestamp()) AS WinStartTime, System.Timestamp() AS WinEndTime, TollId, COUNT(*)
FROM Input TIMESTAMP BY EntryTime
GROUP BY TollId, SlidingWindow(minute, 5)
HAVING COUNT(*) > 3