如何将流

Question

我正在尝试合并一个流

例如，

final Map<String, someOtherObjectToProcess> someObject;

final List<Map<String, Map<String, String>>> list = someObject.entrySet()
            .stream()
            .flatMap(this::getInfoStream)
            .collect(Collectors.toList());

getInfoStream的签名是

public Stream<Map<String, Map<String, String>>> getInfoStream(Map.Entry<String, someOtherObjectToProcess> entry)

如果我使用（Collectors.toList（））我能够得到这些Map对象的列表。

如果使用上述代码，则输出示例：

[{
    "name" : {
        "property":"value"
    }
},

{
    "name2" : {
        "property":"value"
    }
}]

但我想收集到一张有结构的地图上

{
    "name" : {
        "property":"value"
    },
    "name2" : {
        "property":"value"
    }
}

前提是密钥是唯一的。

如何使用Collectors.toMap（）或任何其他替代方法来做到这一点？




Answer 1

在我看来，最具可读性的方法是将所有内容映射到映射。输入，然后使用收集器：：toMap将所有内容收集回地图

import static java.util.stream.Collectors.toMap;

// ...

someObject.entrySet()
          .stream()
          .flatMap(this::getInfoStream)
          .flatMap(map -> map.entrySet().stream())
          .collect(toMap(Map.Entry::getKey, Map.Entry::getValue, (one, two) -> one));

<代码>（一，二）-

Answer 2

解决这个问题的另一种方法是不使用收集器（toList（）），而是使用另一个重载的。收集（）方法与供应商、累加器和组合器：

Stream<Map<String, Map<String, String>>> stream = ...
Map<String, Map<String, String>> result = stream
       .collect(HashMap::new, HashMap::putAll, HashMap::putAll);

Answer 3

匿名用户

当你有

Stream<Map<String, Map<String, String>>> stream = ...

（我假设这是flatMap（this：：getInfoStream）的结果）您可以调用

.flatMap(map -> map.entrySet().stream())

从将生成流的所有映射创建条目流

现在，从该流中，您需要做的就是从地图的每个条目中收集键和值。假设每个键在您可以使用的所有地图中都是唯一的

.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));

但若键不是唯一的，那个么您需要决定应该为同一个键在新映射中放置什么值。我们可以通过填写 零件输入

.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (vOld, vNew) -> ...));
//                                                                                ^^^

其中，vOld保存同一键下结果图中当前保存的值，而vNew保存新值（来自当前流“迭代”）
例如，如果要忽略新值，只需返回旧值/当前由持有的值（vOld，vNew）-

简而言之（假设密钥唯一）：

Map<String, Map<String, String>> combinedMap = 
        /*your Stream<Map<String, Map<String, String>>>*/
        .flatMap(map -> map.entrySet().stream())
        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));