Finestra a cascata (Analisi di flusso di Azure)

Le finestre a cascata sono costituite da una serie di intervalli temporali di dimensioni fisse, contigui e non sovrapposti. Il diagramma seguente illustra un flusso con una serie di eventi e come vengono mappati in finestre di 10 secondi.

Finestra di analisi di

Sintassi

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

Nota

La finestra a cascata può essere usata in uno dei due modi seguenti. Per assicurare la coerenza con la finestra di salto, la funzione Duration può essere usata anche con tutti i tipi di finestre per specificarne le dimensioni. La durata della finestra deve essere una costante float positiva.

Argomenti

timeunit

Unità di tempo per windowsize. La tabella seguente contiene tutti gli argomenti validi per timeunit.

Timeunit	Abbreviazioni
day	dd, d
hour	hh
minute	mi, n
second	ss, s
millisecondo	ms
microsecondo	mcs

windowsize

Intero lungo che descrive le dimensioni della finestra. La finestra è statica e non può essere modificata dinamicamente in fase di esecuzione.

La dimensione massima della finestra è pari a sette giorni.

offsetsize

Per impostazione predefinita, le finestre a cascata sono incluse alla fine della finestra ed esclusive all'inizio, ad esempio 12:00 - 1:00 finestra includeranno eventi che si sono verificati esattamente alle 1:00, ma non includeranno eventi che si sono verificati alle 12:00PM (questi eventi faranno parte della finestra delle 11:00 - 12:00 PM).

Il parametro Offset può essere usato per modificare questo comportamento e includere gli eventi all'inizio della finestra ed escludere quelli che si sono verificati alla fine.

Esempio

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

Considerazioni sul tempo di backup

Ogni operazione della finestra genera un evento alla fine della finestra. Le finestre di Analisi di flusso di Azure vengono aperte all'ora di inizio della finestra e chiuse all'ora di fine della finestra. Ad esempio, se si dispone di una finestra di 5 minuti dalle 12:00 alle 12:05, tutti gli eventi con timestamp maggiore di 12:00 am e fino al timestamp 12:05 includerà all'interno di questa finestra. L'output della finestra sarà un singolo evento basato sulla funzione di aggregazione usata che presenta un timestamp uguale all'ora di fine della finestra. Il timestamp dell'evento di output della finestra può essere proiettato nell'istruzione SELECT usando la proprietà System.Timestamp() usando un alias.

Vedere anche

Finestra di ritaglio
Finestra scorrevole
Windowing