Java 8 MapReduce pour l'informatique distribuée

Cela m'a rendu heureux quand j'ai entendu parler de parallelStream() en Java 8, qui traite sur plusieurs cœurs et rend finalement le résultat dans une seule JVM. Plus de lignes de code multithreading. Pour autant que je sache, cela n'est valable que pour une seule JVM.

Mais que faire si je veux distribuer le traitement sur différentes JVM sur un seul hôte ou même plusieurs hôtes? Java 8 inclut-il une abstraction pour le simplifier?

Dans un tutoriel à dreamsyssoft.com une liste de utilisateurs

private static List<User> users = Arrays.asList(
    new User(1, "Steve", "Vai", 40),
    new User(4, "Joe", "Smith", 32),
    new User(3, "Steve", "Johnson", 57),
    new User(9, "Mike", "Stevens", 18),
    new User(10, "George", "Armstrong", 24),
    new User(2, "Jim", "Smith", 40),
    new User(8, "Chuck", "Schneider", 34),
    new User(5, "Jorje", "Gonzales", 22),
    new User(6, "Jane", "Michaels", 47),
    new User(7, "Kim", "Berlie", 60)
);

Est traité pour obtenir leur âge moyen comme ceci:

double average = users.parallelStream().map(u -> u.age).average().getAsDouble();

Dans ce cas, il est traité sur un seul hôte.

Ma question est: Peut-il être traité en utilisant plusieurs hôtes?

Par exemple Host1 traite la liste ci-dessous et renvoie average1 pour cinq utilisateurs:

new User(1, "Steve", "Vai", 40),
new User(4, "Joe", "Smith", 32),
new User(3, "Steve", "Johnson", 57),
new User(9, "Mike", "Stevens", 18),
new User(10, "George", "Armstrong", 24),

De même, Host2 traite la liste ci-dessous et renvoie average2 pour les cinq utilisateurs restants:

new User(2, "Jim", "Smith", 40),
new User(8, "Chuck", "Schneider", 34),
new User(5, "Jorje", "Gonzales", 22),
new User(6, "Jane", "Michaels", 47),
new User(7, "Kim", "Berlie", 60)

Enfin Host3 calcule le résultat final comme:

average = (average1 + average2)  / 2

En utilisant l'architecture distribuée, il peut être résolu comme à distance. Java 8 a-t-il un moyen plus simple de résoudre le problème avec une abstraction pour cela?

Je connais des frameworks comme Hadoop, Akka et Promises le résolvent. Je parle de Java pur 8. Puis-je obtenir une documentation et des exemples pour parallelStream() pour plusieurs hôtes?