Introduzione alle funzioni finestra di Analisi di flussoIntroduction to Stream Analytics Window functions

In molti scenari di flusso in tempo reale è necessario eseguire operazioni solo sui dati contenuti in finestre temporali.In many real time streaming scenarios, it is necessary to perform operations only on the data contained in temporal windows. Il supporto nativo delle funzioni finestra è una funzionalità cruciale di Analisi di flusso di Azure che pone l'accento sulla produttività degli sviluppatori per la creazione di processi di elaborazione di flussi complessi.Native support for windowing functions is a key feature of Azure Stream Analytics that moves the needle on developer productivity in authoring complex stream processing jobs. Analisi di flusso consente agli sviluppatori di usare finestre a cascata, di salto e temporali scorrevoli per eseguire operazioni temporali sui dati di flusso.Stream Analytics enables developers to use Tumbling, Hopping and Sliding windows to perform temporal operations on streaming data. Vale la pena di sottolineare che tutte le operazioni finestra restituiscono i risultati alla fine della finestra.It is worth noting that all Window operations output results at the end of the window. L'output della finestra sarà un singolo evento basato sulla funzione di aggregazione usata.The output of the window will be single event based on the aggregate function used. All'evento sarà associato il timestamp di fine della finestra e tutte le funzioni finestra sono definite con una lunghezza fissa.The event will have the time stamp of the end of the window and all Window functions are defined with a fixed length. Infine, è importante segnalare che tutte le funzioni finestra devono essere usate in una clausola GROUP BY.Lastly it is important to note that all Window functions should be used in a GROUP BY clause.

Concetti delle funzioni finestra di Analisi di flusso

Finestra a cascataTumbling Window

Le funzioni finestra a cascata vengono usate per segmentare un flusso di dati in segmenti temporali distinti e per eseguire una funzione su tali segmenti, come nell'esempio seguente.Tumbling window functions are used to segment a data stream into distinct time segments and perform a function against them, such as the example below. I principali elementi distintivi di una finestra a cascata sono la ripetitività e la non sovrapposizione, oltre al fatto che un evento non può appartenere a più di una finestra a cascata.The key differentiators of a Tumbling window are that they repeat, do not overlap and an event cannot belong to more than one tumbling window.

Introduzione alle funzioni finestra a cascata di Analisi di flusso

Finestra di saltoHopping Window

Le funzioni finestra di salto consentono di avanzare nel tempo di un periodo fisso.Hopping window functions hop forward in time by a fixed period. Può essere utile pensare a queste finestre come finestre a cascata che possono essere sovrapposte, quindi gli eventi possono appartenere a più di un set di risultati della finestra di salto.It may be easy to think of them as Tumbling windows that can overlap, so events can belong to more than one Hopping window result set. Per creare una finestra di salto uguale a una finestra a cascata, basterebbe specificare dimensioni del salto uguali alle dimensioni della finestra.To make a Hopping window the same as a Tumbling window one would simply specify the hop size to be the same as the window size.

Introduzione alle funzioni finestra di salto di Analisi di flusso

Finestra temporale scorrevoleSliding Window

Le funzioni finestra temporale scorrevole, diversamente dalle finestre a cascata o di salto, generano un output solo quando si verifica un evento.Sliding window functions, unlike Tumbling or Hopping windows, produce an output only when an event occurs. Ogni finestra avrà almeno un evento e la finestra si sposta continuamente in avanti di un € (epsilon).Every window will have at least one event and the window continuously moves forward by an € (epsilon). Come le finestre di salto, gli eventi possono appartenere a più di una finestra temporale scorrevole.Like Hopping Windows, events can belong to more than one Sliding Window.

Introduzione alle funzioni finestra temporale scorrevole di Analisi di flusso

Risorse della Guida per le funzioni finestraGetting help with Window functions

Per ulteriore assistenza, provare il Forum di Analisi dei flussi di AzureFor further assistance, try our Azure Stream Analytics forum

Passaggi successiviNext steps