Java 8 MapReduce用于分布式计算

当我parallelStream()在Java 8中听到它在多个内核上进行处理并最终在单个JVM中返回结果时,我很高兴.没有更多的多线程代码行.据我所知,这仅对单个JVM有效.

但是,如果我想在单个主机甚至多个主机上的不同JVM上分发处理,该怎么办？Java 8是否包含任何用于简化它的抽象？

在dreamsyssoft.com的教程中,用户列表

private static List 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)
);

经过处理以获得他们的平均年龄:

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

在这种情况下,它在单个主机上处理.

我的问题是:它可以使用多个主机进行处理吗？

例如,Host1处理下面的列表并返回average1五个用户:

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),

类似地Host2处理下面的列表并返回average2剩下的五个用户:

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)

最后Host3计算最终结果如:

average = (average1 + average2)  / 2

使用分布式架构,它可以像远程处理一样解决.Java 8是否有一些更简单的方法来解决这个问题？

我知道像Hadoop,Akka和Promises这样的框架可以解决它.我在谈论纯Java 8.我可以parallelStream()为多个主机获取任何文档和示例吗？