Spark Streaming
Difficile 30 pointsCré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.
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.