java - 如何使用 Reactor 框架执行 MapReduce 操作？

Question

有人可以展示如何通过 Reactor 执行映射/归约操作的代码示例吗？框架？

假设我有一个 Collection<Map> 。我想要:

1. 变换每个Map类型为 Foo 的对象的实例并发(每个实例完全独立于另一个实例 - 无需串行/迭代地转换每个实例)。

2. 全部转换后，我想要一个a方法，onReduce(Collection<Foo> foos) ，被调用 - 参数包含所有结果 Foo实例。

Answer 1

在我看来你不需要reduce根本不。 collect和consume适合您:

@Test
public void testCollect() {
    Stream<String> stream = Streams.defer(Arrays.asList("1", "2", "3", "4", "5")).get();
    stream.map(Integer::parseInt)
            .collect()
            .consume(integers -> assertThat(integers, Matchers.contains(1, 2, 3, 4, 5)));
}

此示例 (Java 8) 演示了如何发送 List<String>到 Reactor 的 Stream ，转换每个 item至String , collect他们到List<Integer>并做process关于结果List .

更新

注意collect(5)不需要:Stream适用batchSize来自延期Collection 。看起来像.collect(int batchSize)最近已推出。