Spark Streaming

Difficile 30 points

Créez un pipeline Spark Streaming pour traiter des données en temps réel.

Spark Streaming traite les données en flux. Il divise le flux en micro-batches (DStreams). Les opérations sont similaires aux RDDs mais sur des fenêtres temporelles. L'intégration avec Kafka est courante.

Bravo ! 🎉
Votre réponse est correcte ! Vous avez gagné 30 points.
Pas tout à fait...
Réessayez ! Vous pouvez le faire.

Votre code

Indice
Utilisez StreamingContext(), socketTextStream(), flatMap(), reduceByKey()

Résultat

Cliquez sur "Exécuter le code" pour voir le résultat de votre code. Cliquez sur "Soumettre" pour vérifier si votre réponse est correcte.