Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
✅ Azure Stream Analytics ✅ Fabric Eventstream
Tumblingvensters zijn een reeks vaste, niet-overlappende en aaneengesloten tijdsintervallen. In het volgende diagram ziet u een stroom met een reeks gebeurtenissen en hoe deze worden toegewezen aan tumblingvensters van 10 seconden.
Syntaxis
{TUMBLINGWINDOW | TUMBLING} ( timeunit , windowsize, [offsetsize] )
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit , windowsize ), [Offset(timeunit , offsetsize)] )
Opmerking
Het tumblingvenster kan op de bovenstaande twee manieren worden gebruikt. Om consistentie met het hoppingvenster mogelijk te maken, kan de functie Duur ook worden gebruikt met alle typen vensters om de venstergrootte op te geven. De duur van het venster moet een positieve float-constante zijn.
Argumenten
tijdeenheid
Is de tijdseenheid voor de venstergrootte. De volgende tabel bevat alle geldige tijdeenheidargumenten.
| Tijdeenheid | Afkortingen |
|---|---|
| dagen | dd, d |
| uur | Hh |
| minuut | mi, n |
| tweede | ss, s |
| milliseconde | mevrouw |
| microseconde | Mcs |
vensters aanpassen
Een groot geheel getal dat de grootte van het venster beschrijft. De venstergrootte is statisch en kan tijdens runtime niet dynamisch worden gewijzigd.
De maximale grootte van het venster is 7 dagen.
offsetsize
Standaard zijn tumblingvensters inclusief aan het einde van het venster en exclusief in het begin , bijvoorbeeld 12:00 – 13:00 pm-venster, worden gebeurtenissen opgenomen die precies om 13:00 uur zijn gebeurd, maar bevatten geen gebeurtenissen die om 12:00 uur zijn gebeurd (deze gebeurtenissen maken deel uit van 11:00 tot 12:00 uur).
De offsetparameter kan worden gebruikt om dit gedrag te wijzigen en de gebeurtenissen in het begin van het venster op te nemen en de gebeurtenissen uit te sluiten die aan het einde zijn opgetreden.
Voorbeelden
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
Tijdoverwegingen
Elke vensterbewerking voert een gebeurtenis uit aan het einde van het venster. De vensters van Azure Stream Analytics worden geopend op de begintijd van het venster en gesloten op de eindtijd van het venster. Als u bijvoorbeeld een periode van 5 minuten hebt van 12:00 tot 12:05 uur, worden alle gebeurtenissen met een tijdstempel groter dan 12:00 uur en tot tijdstempel 12:05 uur opgenomen in dit venster. De uitvoer van het venster is één gebeurtenis op basis van de statistische functie die wordt gebruikt met een tijdstempel die gelijk is aan de eindtijd van het venster. De tijdstempel van de uitvoergebeurtenis van het venster kan worden geprojecteerd in de SELECT-instructie met behulp van de eigenschap System.Timestamp() met behulp van een alias.