使用JavaStream条件映射到新对象

Question

我有一个对象流（列表），并希望从该流创建新对象，以插入到Set中。但是，传入List中的两个或多个对象可能会散列到Set中的同一个Key，在这种情况下，我想将第n个List对象中的String追加到Set中已经存在的对象，而不是创建一个新的对象。

类似这样的东西，但以功能形式：

HashSet<ClassB> mySet = new HashSet<>();
for (ClassA instanceA : classAList) {
    if (mySet.contains(ClassB.key(instanceA))) { //static method call to find the key
        mySet.get(instanceA).appendFieldA(instanceA.getFieldA());
    } else {
        mySet.add(new ClassB(instanceA));
    }
}
return mySet;

在功能形式中，我想创建如下内容：

List classAList = new ArrayList<>();
classAList.stream()
.map(instanceA -> new ClassB(instanceA))
.collect(Collectors.toSet());

当然，这忽略了hashmap，我不能将多个ClassA实例中的字段合并到同一个ClassB中。我不知道怎么把它放进去。我是否需要忽略map（）调用并创建一个自定义收集器来执行此任务？似乎有不止一种方法可以做到这一点，但我是新的流。

Answer 1

您可以将这些条目分组到一个映射中，该映射将散列键映射到元素列表，然后再次调用map将该映射转换为您要查找的集合。大概是这样的：

List classAList = new ArrayList<>();
classAList.stream()
.collect(Collectors.groupingBy(instanceA -> ClassB.key(instanceB)))
.entrySet()
.map(entry -> entry.getValue().stream()
   .map(instanceA -> new ClassB(instanceA))
   .reduce(null, (a,b) -> a.appendFieldA(b)))
.collect(Collectors.toSet());

Answer 2

很难理解您真正想要的是什么，因为您的html" target="_blank">代码示例根本不起作用。问题是集合的工作方式与映射不同，您不能要求它提供包含的等效对象。除此之外，您正在为包含（…）和获取（…）调用使用不同的对象。另外，还不清楚ClassB之间的区别。键（instanceA）和新类B（instanceA）是。

让我们尝试重新定义它：

假设我们有一个键类型key和一个方法key。键（instanceA）定义组候选项。然后我们有一个ClassB，它是通过newclassb（instanceA）为一个具有的单个（或主ClassA实例）创建的结果类型。appendFieldA（…）方法，用于在合并两个组成员时接收另一个ClassA实例的值。然后，原始的（前Java

HashMap<Key, ClassB> myMap = new HashMap<>();
for(ClassA instanceA: classAList) {
    Key key=Key.key(instanceA);
    if(myMap.containsKey(key)) {
        myMap.get(key).appendFieldA(instanceA.getFieldA());
    } else {
        myMap.put(key, new ClassB(instanceA));
    }
}

然后，myMap。values（）提供了ClassB实例的集合。如果必须是集合，您可以通过

Set<ClassB> result=new HashSet<>(myMap.values());

请注意，当Key和ClassB与您的代码中的内容相同时，这也可以起作用，但您可以询问自己，是否确实需要这两者，通过创建的实例。键（instanceA）和通过新建ClassB（instanceA）创建的键…

这可以通过Java简化

for(ClassA instanceA: classAList) {
    myMap.compute(Key.key(instanceA), (k,b)-> {
        if(b==null) b=new ClassB(instanceA);
        else b.appendFieldA(instanceA.getFieldA());
        return b;
    });
}

或者，如果你想让它看起来更时尚：

classAList.forEach(instanceA ->
    myMap.compute(Key.key(instanceA), (k,b)-> {
        if(b==null) b=new ClassB(instanceA);
        else b.appendFieldA(instanceA.getFieldA());
        return b;
    })
);

对于流解决方案，有一个问题，合并函数将获得相同类型的两个实例，这里是ClassB，并且不能像上面的compute解决方案那样通过周围的上下文访问ClassA实例。对于流解决方案，我们需要ClassB中的一个方法，它返回第一个ClassA实例，我们将其传递给它的构造函数，比如getFirstInstanceA（）。然后我们可以使用：

Map<Key, ClassB> myMap = classAList.stream()
    .collect(Collectors.toMap(Key::key, ClassB::new, (b1,b2)->{
        b1.appendFieldA(b2.getFirstInstanceA().getFieldA());
        return b1;
    }));