Finestra mobile

✅ Flusso di eventi dell'infrastruttura di Analisi ✅ di flusso di Azure

A differenza delle finestre a cascata, saltando finestre pianificate sovrapposte. Una specifica della finestra di salto è costituita da tre parametri: timeunit, finestrezza (durata di ogni finestra) e hopsize (per quanto ogni finestra si sposta in avanti rispetto a quella precedente). Inoltre, offsetsize può essere usato come quarto parametro facoltativo. Si noti che una finestra a cascata è semplicemente una finestra di salto la cui "hop" è uguale alla sua "dimensione".

La figura seguente mostra un flusso con una serie di eventi. Ogni casella rappresenta una finestra di salto e gli eventi conteggiati come parte di tale finestra, presupponendo che l'hop sia 5 e che la "dimensione" sia 10.

Diagramma Analisi di flusso di Analisi di flusso di flusso

Sintassi

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

Annotazioni

La finestra di salto può essere usata nei due modi precedenti. Se le finestre e l'hopsize hanno lo stesso timeunit, è possibile usarlo senza le funzioni Duration e Hop. La funzione Duration può essere usata anche con altri tipi di finestre per specificare le dimensioni della finestra.

Argomenti

timeunit

Unità di tempo per windowsize o hopsize. Nella tabella seguente sono elencati tutti gli argomenti timeunit validi.

Timeunit	Abbreviazioni
giorno	dd, d
ora	Hh
minuto	mi, n
secondo	ss, s
millisecondo	ms
microsecondo	Mcs

windowsize

Intero grande che descrive le dimensioni della finestra. Windowsize è statico e non può essere modificato in modo dinamico in fase di esecuzione.

Le dimensioni massime della finestra in tutti i casi sono 7 giorni.

hopsize

Intero grande che descrive le dimensioni dell'hop.

offsetsize

Per impostazione predefinita, le finestre di salto sono incluse alla fine della finestra ed esclusive all'inizio, ad esempio le 12:05 - 13:05 finestra includeranno eventi che si sono verificati esattamente alle 13:05, ma non includeranno eventi che si sono verificati alle 12:05:PM (questi eventi faranno parte della finestra delle 12:00 - 01:00 PM).
Il parametro Offset può essere usato per modificare il comportamento e includere gli eventi all'inizio della finestra ed escludere quelli che si sono verificati alla fine.

Esempi

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))  
  

Considerazioni sul tempo

Ogni operazione di finestra restituisce un evento alla fine della finestra (nel caso di finestre di salto, questo avviene a ogni dimensione dell'hop). 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 ha una finestra di 5 minuti dalle 12:00 alle 12:05, tutti gli eventi con timestamp maggiore delle 12:00 e fino al timestamp 12:05 inclusi in questa finestra. L'output della finestra sarà un singolo evento basato sulla funzione di aggregazione usata con un timestamp uguale all'ora di fine dell'intervallo. Il timestamp dell'evento di output della finestra può essere proiettato nell'istruzione SELECT usando la proprietà System.Timestamp() usando un alias.