群组、分区、下游收集器

群组和分区（P23-25）

将具有相同特性的值群聚成组是非常常见的，并且groupingBy方法直接就支持它

Map<String, List<Locale>> countryToLocales = locales.collect(Collectors.goupingBy(Locale::getCountry));
//函数Locale::getCountry是群组的分类函数。
//Yields locales [it_CH, de_CH, fr_CH]
List<Locale> swissLocales = countryToLocales.get("CH");

当分类函数是断言函数(即返回boolean值的函数)时，流的元素可以分区为两个列表：该函数返回true的元素和其他的元素。在这种情况下，使用partitioningBy比使用groupingBy要更高效。

Map<Bolean,List<Locale>> englishAndOtherLocales = locales.collect(
Collectors.partitioningBy(l -> l.getLanguage().equals("en")));

List<Locale> englishLocales = engLishAndOtherLocales.get(true);

• java.util.stream.Collector 8

  • static Collector>> groupingBy(Function<? extend T,? extend K> classifier)

  • static Collector>> groupingByConcurrent(Function<? extend T,? extend K> classifier)

    • 产生一个收集器，它会产生一个映射表或并发映射表，其键是将classifier应用于所有收集到的元素上所产生的结果，而值是由具有相同键的元素构成的一个个列表。

  • static Collector>> partitioningBy(Predicate<? super T> predicate)

    • 产生一个收集器，它会产生一个映射表，其键是true/false，而值是由满足/不满足断言的元素构成的列表。

下游收集器（P24-28）

groupingBy方法会产生一个映射表，它的每个值都是一个列表。如果想要以某种方式来处理这些列表，就需要提供一个“下游收集器”。

import java.util.stream.Collectors.*

//将群组元素约简为数字的收集器
//counting会产生收集到的元素的个数
Map<String, Long> countryToLocaleCounts = locales.collect(
    groupingBy(Locale::getCountry, counting()));

//summingInt会接受一个函数作为引元，将该函数应用到下游元素中，并产生它们的和。
Map<String, Integer> stateToCityPopulation = cities.collect(
    groupingBy(City::getState, summingInt(City::getPopulation)));

//maxBy和minBy会接受一个比较器，并产生下游元素中的最大值和最小值
Map<String, Optional<City>> stateToLargestCity = cities.collect(
    groupingBy(City::getState, maxBy(Coparator.comparing(City::getPopulation))));

//mapping方法会产生将函数应用到下游结果上的收集器，并将函数值传递给另一个收集器
Map<String, Optional<String>> stateToLongestCityName =cities.collect(
    groupingBy(City::getState,
    mapping(City::getName,
    maxBy(Comparator.comparing(String::length)))));

将收集器组合起来是一种很强大的方式，但是它也可能会导致产生非常复杂的表达式。它们的最佳用法是与groupingBy和partitioningBy一起处理“下游的”映射表中的值。否则，应该直接在流上应用诸如map、reduce、count、max和min这样的方法。

• java.util.stream.Collectiors 8

  • static Collector counting()

    • 产生一个可以对收集到的元素进行计数的收集器。

  • static Collector summingInt(ToIntFunction<? super T> mapper)

  • static Collector summingLong(ToLongFunction<? super T> mapper)

  • static Collector summingDouble(ToDoubleFunction<? super T> mapper)

    • 产生一个收集器，对将mapper应用到收集到的元素上之后产生的值计算总和。

  • static Collector> maxBy(Comparator<? super T> comparator)

  • static Collector> minBy(Comparator<? super T> comparator)

    • 产生一个收集器，使用comparator指定的排序方法，计算收集到的元素中的最大值/最小值。

  • static Collector mapping(Function<? super T,? extends U> mapper, Collector<？ super U,A,R> downstream)

    • 产生一个收集器，它会产生一个映射表，其键是将mapper应用到收集到的数据上面产生的，其值是使用downstream收集器收集到的具有相同键的元素。