根据不同的参数将集合（使用 java 8 流）拆分为更小的组件

Question

这是这个问题的延续Java 8 stream compare two objects and run a function on them

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

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

我的问题是根据一些动态参数将集合（使用 java 8 流）拆分为更小的组件。 动态参数可以根据传递给方法 splitParts 的不同条件（在这里，我给出的示例为 getPartId() 相同）而变化，其返回类型是 List of Set of Parts

List<Set<Parts>> splitParts(BigRequest big){}

我尝试了以下方法：

 //groupingBy function but that returns a Map 
   Map<String, List<Parts>> parts = big.getParts().stream().collect(Collectors.groupingBy(Parts::getPartId));

//doesn't do it accurately
    big.getParts().stream().filter(p -> p.getPartId.equals(p.getPartId())).collect();

如何根据动态参数拆分流（可能通过在 reduce 方法上调用功能接口），然后在其上运行方法？

我的函数的签名是

List<Set<Parts>> splitParts(BigObject b){}

我认为做这样的事情可能有助于保持分裂条件的动态，但我不知道该怎么做？

 big.getParts().stream().reduce(MyFuncInterface::divide);

然后使用 forEach()，我想我可以遍历 List 并调用 abc() 方法。

我怎样才能做得更好？

非常感谢这里的任何帮助。

Answer 1

如果您想要List<Set<Parts>>，请先更改您的代码以获取Map<String, Set<Parts>>：

Map<String, Set<Parts>> parts = big.getParts().stream().collect(
        Collectors.groupingBy(Parts::getPartId, Collectors.toSet()));

调用parts.values() 将返回Collection<Set<Parts>>，因此将Collection 转换为List：

List<Set<Parts>> list = new ArrayList<>(parts.values());

或者你可以重新流式传输它，这样你就可以在一个调用链中完成它：

List<Set<Parts>> list = big.getParts()
                           .stream()
                           .collect(Collectors.groupingBy(Parts::getPartId,
                                                          Collectors.toSet()))
                           .values()
                           .stream()
                           .collect(Collectors.toList());