Scopri come elaborare dati in tempo reale utilizzando le stesse API Spark che utilizzi per l'elaborazione batch
Archived. This article has not been updated since the publish date above. The dynamic nature of information means that previously accurate content can become outdated or even obsolete over time. Readers are advised to exercise due diligence and cross-check any information found in this blog post before making decisions or adopting any practices based on said information.
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.
Iscriviti al nostro blog e ricevi gli ultimi articoli direttamente nella tua casella di posta.