Hashmap with Streams in Java 8 Streams 收集 Map 的值

Posted

技术标签:

【中文标题】Hashmap with Streams in Java 8 Streams 收集 Map 的值【英文标题】:Hashmap with Streams in Java 8 Streams to collect value of Map 【发布时间】:2015-06-19 22:56:46 【问题描述】:

让我们考虑一个哈希图

Map<Integer, List> id1 = new HashMap<Integer,List>();

我在两个哈希图中都插入了一些值。

例如,

List<String> list1 = new ArrayList<String>();

list1.add("r1");
list1.add("r4");

List<String> list2 = new ArrayList<String>();
list2.add("r2");
list2.add("r5");

List<String> list3 = new ArrayList<String>();
list3.add("r3");
list3.add("r6");

id1.put(1,list1);
id1.put(2,list2);
id1.put(3,list3);
id1.put(10,list2);
id1.put(15,list3);

Q1) 现在我想对 hashmap 中的键应用过滤条件并检索相应的值(List)。

例如:这里我的查询是key=1,输出应该是'list1'

我写的

id1.entrySet().stream().filter( e -> e.getKey() == 1);
            

但我不知道如何将列表检索为此流操作的输出。

Q2)我想再次对 hashmap 中的键应用过滤条件并检索相应的列表列表。

例如:这里我的查询是 key=1%(即 key 可以是 1,10,15),输出应该是 'list1','list2','list3'(列表列表)。

【问题讨论】:

不要使用半生不熟的泛型类型。最有可能的是,您的地图应该是 Map&lt;Integer, List&lt;String&gt;&gt; 而不是 Map&lt;Integer, List&gt; 【参考方案1】:

如果您确定最多只能获得一个通过过滤器的元素(由您的过滤器保证),您可以使用findFirst

Optional<List> o = id1.entrySet()
                      .stream()
                      .filter( e -> e.getKey() == 1)
                      .map(Map.Entry::getValue)
                      .findFirst();

一般情况下,如果过滤器可能匹配多个List,你可以将它们收集到List of Lists中:

List<List> list = id1.entrySet()
                     .stream()
                     .filter(.. some predicate...)
                     .map(Map.Entry::getValue)
                     .collect(Collectors.toList());

【讨论】:

【参考方案2】:

您需要做的是从Map.entrySet() 中创建一个Stream

// Map<K, V> --> Set<Map.Entry<K, V>> --> Stream<Map.Entry<K, V>>
map.entrySet().stream()

从现在开始,您可以.filter() 覆盖这些条目。例如:

// Stream<Map.Entry<K, V>> --> Stream<Map.Entry<K, V>>
.filter(entry -> entry.getKey() == 1)

并且要从中获取值你.map():

// Stream<Map.Entry<K, V>> --> Stream<V>
.map(Map.Entry::getValue)

最后需要收藏成List

// Stream<V> --> List<V>
.collect(Collectors.toList())

如果您只有一个条目,请改用它(注意:此代码假定存在一个值;否则,请使用.orElse();有关详细信息,请参阅javadoc of Optional):

// Stream<V> --> Optional<V> --> V
.findFirst().get()

【讨论】:

@user2336315 是的,此代码假定该值存在; OP对此不是很清楚。阿韦尔【参考方案3】:

对于您的第二季度,您的问题已经有了答案。对于您的 Q1,更一般地说,当您知道键的过滤应该给出唯一值时,根本不需要使用 Streams。

只需使用getgetOrDefault,即:

List<String> list1 = id1.getOrDefault(1, Collections.emptyList());

【讨论】:

【参考方案4】:

你也可以这样做

public Map<Boolean, List<Student>> getpartitionMap(List<Student> studentsList) 

    List<Predicate<Student>> allPredicates = getAllPredicates();
    Predicate<Student> compositePredicate =  allPredicates.stream()
                             .reduce(w -> true, Predicate::and)
     Map<Boolean, List<Student>> studentsMap= studentsList
                .stream()
                .collect(Collectors.partitioningBy(compositePredicate));
    return studentsMap;


public List<Student> getValidStudentsList(Map<Boolean, List<Student>> studentsMap) throws Exception 

    List<Student> validStudentsList =  studentsMap.entrySet()
             .stream()
             .filter(p -> p.getKey() == Boolean.TRUE)
             .flatMap(p -> p.getValue().stream())
             .collect(Collectors.toList());

    return validStudentsList;


public List<Student> getInValidStudentsList(Map<Boolean, List<Student>> studentsMap) throws Exception 

    List<Student> invalidStudentsList = 
             partionedByPredicate.entrySet()
             .stream()
             .filter(p -> p.getKey() == Boolean.FALSE)
             .flatMap(p -> p.getValue().stream())
             .collect(Collectors.toList());

    return invalidStudentsList;


使用flatMap,您将只获得List&lt;Student&gt; 而不是List&lt;List&lt;Student&gt;&gt;

谢谢

【讨论】:

【参考方案5】:

使用 keySet-

id1.keySet().stream()
        .filter(x -> x == 1)
        .map(x -> id1.get(x))
        .collect(Collectors.toList())

【讨论】:

【参考方案6】:

也许示例过于简单,但您不需要此处的 Java 流 API。直接使用地图即可。

 List<String> list1 = id1.get(1); // this will return the list from your map

【讨论】:

以上是关于Hashmap with Streams in Java 8 Streams 收集 Map 的值的主要内容,如果未能解决你的问题,请参考以下文章

如何使用 Java Streams 从 HashMap 的 ArrayList 中获取字符串

[RxJS] Combining Streams with CombineLatest

[RxJS] Sharing Streams with Share

[RxJS] Handling Multiple Streams with Merge

[Recompose] Make Reusable React Props Streams with Lenses

Kafka Streams“Consumed.with()”与KafkaAvroDeserializer