Streaming Map/Reduce

En général, la diffusion en continu vous permet d'exécuter des programmes écrits dans des langages autres que Java en tant que tâches map/reduce. Un tel programme lit des données à partir de l'entrée standard et affiche les résultats sur la sortie standard. Chaque ligne d'entrée se compose d'une touche et d'une valeur, séparées par un tabulateur. Le programme traite les données ligne par ligne et produit des paires clé-valeur séparées par des tabulations. La diffusion en continu ne convient qu'au traitement de données textuelles.