streaming strutturato

Structured Streaming è un'API di alto livello per l'elaborazione in streaming che è diventata disponibile in Spark 2.2. Structured Streaming consente di prendere le stesse operazioni eseguite in modalità batch utilizzando le API strutturate di Spark ed eseguirle in modalità streaming. In questo modo si riduce la latenza e si abilita l'elaborazione incrementale. L'aspetto migliore di Structured Streaming è che consente di generare rapidamente valore da sistemi di streaming praticamente senza alcuna modifica di codice. Inoltre, semplifica i ragionamenti perché consente di scrivere il lavoro in batch con lo scopo di prototiparlo, per poi convertirlo in un lavoro in streaming. Tutto ciò funziona grazie all'elaborazione incrementale dei dati.