Java8：对Stream执行减少操作

Question

我有一个java。util。流动包含键值对的流，如：

<1,3> <1,5> <3,1> <4,2> <4,7> <4,8>

现在，我想合并所有具有相同密钥的条目：

<1,[3,5]>  <3,[1]> <4,[2,7,8]>

数据已经排序，因此只需合并连续的数据集。

现在，我正在寻找一种方法来转换上述流的内容，而不将所有数据集加载到内存中。

我更喜欢得到一个java.util.stream.Stream，结果是一个不同的对象类型包含一个值列表，而不是一个单独的值。

我唯一的方法是一个自定义迭代器，它执行合并，但是转换为迭代器并返回到流似乎非常难看。

最好的方法是什么？

Answer 1

这是SteamEx的解决方案。

int[][] datasets = { { 1, 3 }, { 1, 5 }, { 3, 1 }, { 4, 2 }, { 4, 7 }, { 4, 8 } };

StreamEx.of(datasets) //
        .collapse((a, b) -> a[0] == b[0], groupingBy(a -> a[0], mapping(a -> a[1], toList()))) //
        .forEach(System.out::println);

您可以用数据集对象替换int[]。我们可以添加peek来验证它是否是延迟加载/计算：

StreamEx.of(datasets) //
        .peek(System.out::println) //
        .collapse((a, b) -> a[0] == b[0], groupingBy(a -> a[0], mapping(a -> a[1], toList()))) //
        .limit(1) //
        .forEach(System.out::println);