Java 8 流比较两个对象并在它们上运行一个函数

Question

我有一个流，我想根据匹配的 Id 将其划分为更小的部分，然后在每个部分/元素上应用一些处理逻辑。

class BigRequest{
String bId;
List<Parts> parts;
//getters and setter here
}

Class Parts{
String pId;
String partId;
//getters and setter here
}

当不同零件的 partId 相同时，我想分离并创建大小为 10 的零件列表。

如何使用 filter 或 reduce 或 groupingBy 函数来比较两个元素并将它们放到一个列表中？ 我试过像下面这样的过滤器，不带 p1 变量：

big.stream().filter( p -> p.getPartId() == p1.getPartId()) //error

这样尝试过groupingBy

big.stream().collect(Collectors.groupingBy(Parts::getPartId) //error

我想遍历另一个过滤/简化列表并调用另一个名为 abc() 的函数。如何使用 Java Streams 做到这一点？

伪：

big.getParts().stream.
//dividing logic logic
for(i < parts.size)
    abc(p)

谢谢

Answer 1

你可能会使用这样的东西：

 Map<String,List<Parts>> commonId = big.getParts().
                stream().
                collect(
                        Collectors.groupingBy(
                            Parts::getPartId,
                            Collectors.mapping(
                                Function.identity(),
                                Collectors.toList()
                            )
                        )
                ); 

之后，您只需要遍历地图并应用您的函数。 commonId.entrySet().stream().map(entry -> apply(entry))...

更新 我们可以省略Collectors.mapping(Function.identity(),Collectors.toList()) 部分，因为它是groupingBy 的默认行为

Map<String,List<Parts>> commonId = big.getParts().
                    stream().
                    collect(
                            Collectors.groupingBy(
                                Parts::getPartId
                            )
                    );