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

Question

这是这个问题的延续Java8流比较两个对象并在它们上运行一个函数

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

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

我的问题是根据一些动态参数将集合（使用Java8流）拆分成更小的组件。动态参数可以根据传递给方法splitParts的不同条件（这里，我给出的示例是getPartId（）相同）而改变，该方法的返回类型是一组部件的列表

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();

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

我的函数签名是

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

我想这样做可能有助于保持分裂状态的动态性，但我不知道该怎么做？

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

然后使用forEach（），我想我可以迭代列表并调用abc（）方法。

我怎样才能做得更好？

非常感谢您的帮助。

Answer 1

如果你想要一个列表

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

调用部件。values（）将返回一个集合

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());