Java Streams: Werte durch inneren Kartenschlüssel gruppiert

Question

Ich habe Map<A, Map<B, C>> und ich möchte Map<B, List<C>> davon mit Java-Streams bekommen.

ich versuche, es zu tun, wie folgt:

public <A, B, C> Map<B, List<C>> groupsByInnerKey(Map<A, Map<B, C>> input) { 
    return input.values() 
      .stream() 
      .flatMap(it -> it.entrySet().stream()) 
      .collect(Collectors.groupingBy(Map.Entry::getKey)); 
} 

Was ich erwarte:

• flatMap eine Funktion Stream von Map.Entry<B, C>
• collect(Collectors.groupingBy(...)) nimmt gibt, die Map.Entry<B, C> angewendet wird, und kehrt B, somit sammelt es Werte von C in List<C>.

Aber es nicht kompiliert, wörtlich:

Nicht statische Methode kann nicht von einem statischen Kontext referenziert wird

bei Map.Entry::getKey in der letzten Zeile.

Kann jemand erklären, was falsch ist oder was ist der richtige Weg, um das zu erreichen, was ich will?

Answer 1

Ihr Stream ist zusammengesetzt aus Map.Entry Objekte, sondern wollen Sie sammeln möchten ist eigentlich der Wert des Eintrags , nicht der Eintrag selbst. Mit Ihrem aktuellen Code erhalten Sie eine Map<B, List<Map.Entry<B, C>>>.

Als solche verpassen Sie nur einen Anruf an Collectors.mapping. Dieser Collector bildet das Stream-Element mit der angegebenen Mapper-Funktion ab und sammelt dieses Ergebnis im Downstream-Container. In diesem Fall lautet der Mapper Map.Entry::getValue (der Wert wird also vom Karteneintrag zurückgegeben), und der nachgeordnete Kollektor sammelt sich in List.

public <A, B, C> Map<B, List<C>> groupsByInnerKey(Map<A, Map<B, C>> input) { 
    return input.values() 
      .stream() 
      .flatMap(it -> it.entrySet().stream()) 
      .collect(Collectors.groupingBy(
       Map.Entry::getKey, 
       Collectors.mapping(Map.Entry::getValue, Collectors.toList()) 
      )); 
} 

Answer 2

Ihre Stream-Pipeline gibt eine Map<B, List<Map.Entry<B,C>>> zurück, keine Map<B, List<C>>.

Zu bekommen, was ein Map<B, List<C>>, benötigen Sie einen mapping hinzufügen, die Map.Entry<B,C>-C Karte würde:

return input.entrySet() 
     .stream() 
     .flatMap(it -> it.getValue().entrySet().stream()) 
     .collect(Collectors.groupingBy(Map.Entry::getKey,Collectors.mapping(Map.Entry::getValue,Collectors.toList())));