Java 8分组成Peek

Question

我最近了解了Java8中的流，并开始使用它们。现在我有一个关于groupingby收集器方法的问题：

我通常使用。NET，所以我将JavaStream 与。NETIEnumerable 进行了比较（知道它们不一样）。在此比较之后，列表 存储元素，而特定的流/IEnumerable应用操作。一个例子：

C#:

elements.Where(x => x.Value == 5).ToList();

elements.stream().filter(x -> x.getValue() == 5).collect(Collectors.toList());

data.stream()
    .map( ... ).filter( ... ) // Some operations
    .collect(groupingBy(Chunk::getName, summingLong(Chunk::getValue)));

这个查询的结果是一个映射 ，我可以处理它，但是假设我想继续处理这个数据，而不是存储它。我目前的方法很琐碎：

    ...
    .collect(groupingBy(Chunk::getName, summingLong(Chunk::getValue)))
    .entrySet().stream().
    .map( ... ) // Do more operations

但是通过这种方式，我离开流，将第一个结果存储在一个映射中，并打开一个新的流继续。有没有一种方法可以在没有收集器的情况下进行分组，这样我就可以“停留”在流中？

Answer 1

只要可以将操作描述为收集器,您就可以在下游收集器中做任何您喜欢做的事情。目前，只有与中间操作map等效的mapping收集器，但是Java9还将添加filtering和flatmapping（您也可以在Java8中自行实现），并且几乎每个终端操作都有等效的操作。

当然，一个嵌套的收集器设备将看起来完全不同于一个流操作链做同样的…

但是，如果要处理完整的组，则没有办法先完成grouping集合。这不是API的限制，而是分组操作或任何一般操作的固有特性，如果您想要处理一个完整的结果，您需要首先完成该操作。不管API看起来如何（例如，您可以在收集器中以收集然后类似的方式隐藏后续操作），创建和填充映射是不可避免的，因为它是负责维护组的映射。这些组由map的键和查找逻辑确定，因此，例如，将sortedmap与自定义比较器一起使用，或者将identityHashmap一起使用，可以完全更改分组逻辑。