Regrouper en comptant dans l'API de flux Java 8

J'essaie de trouver un moyen simple dans l'API de flux Java 8 pour faire le regroupement, je viens avec cette méthode complexe!

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

list.add("Hello");
list.add("Hello");
list.add("World");

Map<String, List<String>> collect = list.stream().collect(
        Collectors.groupingBy(o -> o));
System.out.println(collect);

List<String[]> collect2 = collect
        .entrySet()
        .stream()
        .map(e -> new String[] { e.getKey(),
                String.valueOf(e.getValue().size()) })
        .collect(Collectors.toList());

collect2.forEach(o -> System.out.println(o[0] + " >> " + o[1]));

J'apprécie votre contribution.

Je pense que vous cherchez juste la surcharge qui en prend une autre Collectorpour spécifier quoi faire avec chaque groupe ... et ensuite Collectors.counting()faire le comptage:

import java.util.*;
import java.util.stream.*;

class Test {
    public static void main(String[] args) {
        List<String> list = new ArrayList<>();

        list.add("Hello");
        list.add("Hello");
        list.add("World");

        Map<String, Long> counted = list.stream()
            .collect(Collectors.groupingBy(Function.identity(), Collectors.counting()));

        System.out.println(counted);
    }
}

Résultat:

{Hello=2, World=1}

(Il y a aussi la possibilité d'utiliser groupingByConcurrentpour plus d'efficacité. Quelque chose à garder à l'esprit pour votre vrai code, si ce serait sûr dans votre contexte.)

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

list.add("Hello");
list.add("Hello");
list.add("World");

Map<String, List<String>> collect = list.stream()
                                        .collect(Collectors.groupingBy(o -> o));
collect.entrySet()
       .forEach(e -> System.out.println(e.getKey() + " - " + e.getValue().size()));

Voici un exemple de liste d'objets

Map<String, Long> requirementCountMap = requirements.stream().collect(Collectors.groupingBy(Requirement::getRequirementType, Collectors.counting()));

Voici des options légèrement différentes pour accomplir la tâche à accomplir.

utilisant toMap:

list.stream()
    .collect(Collectors.toMap(Function.identity(), e -> 1, Math::addExact));

utilisant Map::merge:

Map<String, Integer> accumulator = new HashMap<>();
list.forEach(s -> accumulator.merge(s, 1, Math::addExact));

Voici la solution simple de StreamEx

StreamEx.of(list).groupingBy(Function.identity(), Collectors.countingInt());

Réduisez le code passe-partout: collect(Collectors.

Si vous êtes prêt à utiliser une bibliothèque tierce, vous pouvez utiliser la Collectors2classe dans Eclipse Collections pour convertir le Listen un Bagfichier Stream. A Bagest une structure de données conçue pour le comptage .

Bag<String> counted =
        list.stream().collect(Collectors2.countBy(each -> each));

Assert.assertEquals(1, counted.occurrencesOf("World"));
Assert.assertEquals(2, counted.occurrencesOf("Hello"));

System.out.println(counted.toStringOfItemToCount());

Production:

{World=1, Hello=2}

Dans ce cas particulier, vous pouvez simplement collectle Listdirectement dans un fichier Bag.

Bag<String> counted = 
        list.stream().collect(Collectors2.toBag());

Vous pouvez également créer le Bagsans utiliser de Streamen adaptant le Listavec les protocoles des collections Eclipse.

Bag<String> counted = Lists.adapt(list).countBy(each -> each);

ou dans ce cas particulier:

Bag<String> counted = Lists.adapt(list).toBag();

Vous pouvez également créer le sac directement.

Bag<String> counted = Bags.mutable.with("Hello", "Hello", "World");

A Bag<String>est comme a Map<String, Integer>en ce sens qu'il garde en interne la trace des clés et de leur décompte. Mais, si vous demandez une Mapclé qu'il ne contient pas, il reviendra null. Si vous demandez à un Bagune clé qu'il ne contient pas occurrencesOf, il renverra 0.

Remarque: je suis un committer pour les collections Eclipse.