compact1, compact2, compact3

java.util.stream

Коллекторы класса

java.lang. Объект

java.util.stream. Коллекторы

public final class Collectors
extends Object

Реализации Collector та реализация различные полезные операции сокращения, такие как накапливающиеся элементы в наборы, суммируя элементы согласно различным критериям, и т.д.

Следующее является примерами использования предопределенного Collector реализации в Collectors с Stream API, чтобы выполнить изменчивые задачи сокращения:

     // Accumulate elements into a List
     List<Person> list = people.collect(Collectors.toList());

     // Accumulate elements into a TreeSet
     List<Person> list = people.collect(Collectors.toCollection(TreeSet::new));

     // Convert elements to strings and concatenate them, separated by commas
     String joined = stream.map(Object::toString)
                           .collect(Collectors.toStringJoiner(", "))
                           .toString();

     // Find highest-paid employee
     Employee highestPaid = employees.stream()
                                     .collect(Collectors.maxBy(Comparators.comparing(Employee::getSalary)));

     // Group employees by department
     Map<Department, List<Employee>> byDept
         = employees.stream()
                    .collect(Collectors.groupingBy(Employee::getDepartment));

     // Find highest-paid employee by department
     Map<Department, Employee> highestPaidByDept
         = employees.stream()
                    .collect(Collectors.groupingBy(Employee::getDepartment,
                                                   Collectors.maxBy(Comparators.comparing(Employee::getSalary))));

     // Partition students into passing and failing
     Map<Boolean, List<Student>> passingFailing =
         students.stream()
                 .collect(Collectors.partitioningBy(s -> s.getGrade() >= PASS_THRESHOLD);

 

Объяснение TODO параллельного набора

С тех пор:

1.8

Сводка метода

Модификатор и Тип	Метод и Описание
static <T> Collector<T,Long>	counting() Возвраты a Collector<T, Long> это считает число входных элементов.
static <T> BinaryOperator<T>	firstWinsMerger() Возвращает функцию слияния, подходящую для использования в Map.merge() или toMap(), который реализует "первые победы" политика.
static <T,K> Collector<T,Map<K,List<T>>>	groupingBy(Function<? super T,? extends K> classifier) Возвраты a Collector реализация "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации.
static <T,K,D> Collector<T,Map<K,D>>	groupingBy(Function<? super T,? extends K> classifier, Collector<? super T,D> downstream) Возвраты a Collector реализация каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector.
static <T,K,D,M extends Map<K,D>> Collector<T,M>	groupingBy(Function<? super T,? extends K> classifier, Supplier<M> mapFactory, Collector<? super T,D> downstream) Возвраты a Collector реализация каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector.
static <T,K> Collector<T,ConcurrentMap<K,List<T>>>	groupingByConcurrent(Function<? super T,? extends K> classifier) Возвраты a Collector реализация параллельной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации.
static <T,K,D> Collector<T,ConcurrentMap<K,D>>	groupingByConcurrent(Function<? super T,? extends K> classifier, Collector<? super T,D> downstream) Возвраты a Collector реализация параллельной каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector.
static <T,K,D,M extends ConcurrentMap<K,D>> Collector<T,M>	groupingByConcurrent(Function<? super T,? extends K> classifier, Supplier<M> mapFactory, Collector<? super T,D> downstream) Возвращает параллельное Collector реализация каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector.
static <T> BinaryOperator<T>	lastWinsMerger() Возвращает функцию слияния, подходящую для использования в Map.merge() или toMap(), который реализует "последние победы" политика.
static <T,U,R> Collector<T,R>	mapping(Function<? super T,? extends U> mapper, Collector<? super U,R> downstream) Адаптирует a Collector<U,R> к a Collector<T,R> применяя отображающуюся функцию к каждому входному элементу перед накоплением.
static <T> Collector<T,T>	maxBy(Comparator<? super T> comparator) Возвраты a Collector<T, T> это производит максимальный элемент согласно данному Comparator.
static <T> Collector<T,T>	minBy(Comparator<? super T> comparator) Возвраты a Collector<T, T> это производит минимальный элемент согласно данному Comparator.
static <T> Collector<T,Map<Boolean,List<T>>>	partitioningBy(Predicate<? super T> predicate) Возвраты a Collector который делит входные элементы согласно a Predicate, и организует их в a Map<Boolean, List<T>>.
static <T,D> Collector<T,Map<Boolean,D>>	partitioningBy(Predicate<? super T> predicate, Collector<? super T,D> downstream) Возвраты a Collector который делит входные элементы согласно a Predicate, уменьшает значения в каждом разделе согласно другому Collector, и организует их в a Map<Boolean, D> чьи значения являются результатом нисходящего сокращения.
static <T> Collector<T,T>	reducing(BinaryOperator<T> op) Возвраты a Collector<T,T> который выполняет сокращение его входных элементов под указанным BinaryOperator.
static <T> Collector<T,T>	reducing(T identity, BinaryOperator<T> op) Возвраты a Collector<T,T> который выполняет сокращение его входных элементов под указанным BinaryOperator.
static <T,U> Collector<T,U>	reducing(U identity, Function<? super T,? extends U> mapper, BinaryOperator<U> op) Возвраты a Collector<T,U> который выполняет сокращение его входных элементов под указанной функцией отображения и BinaryOperator.
static <T> Collector<T,Long>	sumBy(Function<? super T,Long> mapper) Возвраты a Collector<T, Long> это производит сумму долго оцененной функции, которой применяются к входной элемент.
static <T> BinaryOperator<T>	throwingMerger() Возвращает функцию слияния, подходящую для использования в Map.merge() или toMap(), который всегда бросает IllegalStateException.
static <T,C extends Collection<T>> Collector<T,C>	toCollection(Supplier<C> collectionFactory) Возвраты a Collector это накапливает входные элементы в новое Collection, во встречаются с порядком.
static <T,K,U> Collector<T,ConcurrentMap<K,U>>	toConcurrentMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper) Накопите элементы в a ConcurrentMap чьи ключи и значения являются результатом применения отображающихся функций к входным элементам.
static <T,K,U> Collector<T,ConcurrentMap<K,U>>	toConcurrentMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper, BinaryOperator<U> mergeFunction) Накопите элементы в a ConcurrentMap чьи ключи и значения являются результатом применения отображающихся функций к входным элементам.
static <T,K,U,M extends ConcurrentMap<K,U>> Collector<T,M>	toConcurrentMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper, BinaryOperator<U> mergeFunction, Supplier<M> mapSupplier) Накопите элементы в a ConcurrentMap чьи ключи и значения являются результатом применения отображающихся функций к входным элементам.
static <T> Collector<T,DoubleSummaryStatistics>	toDoubleSummaryStatistics(ToDoubleFunction<? super T> mapper) Возвраты a Collector который применяется double- производящий отображающий функцию на каждый входной элемент, и сводную статистику возвратов для получающихся значений.
static <T> Collector<T,IntSummaryStatistics>	toIntSummaryStatistics(ToIntFunction<? super T> mapper) Возвраты a Collector который применяется int- производящий отображающий функцию на каждый входной элемент, и сводную статистику возвратов для получающихся значений.
static <T> Collector<T,List<T>>	toList() Возвраты a Collector это накапливает входные элементы в новое List.
static <T> Collector<T,LongSummaryStatistics>	toLongSummaryStatistics(ToLongFunction<? super T> mapper) Возвраты a Collector который применяется long- производящий отображающий функцию на каждый входной элемент, и сводную статистику возвратов для получающихся значений.
static <T,K,U> Collector<T,Map<K,U>>	toMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper) Накопите элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам.
static <T,K,U> Collector<T,Map<K,U>>	toMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper, BinaryOperator<U> mergeFunction) Накопите элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам.
static <T,K,U,M extends Map<K,U>> Collector<T,M>	toMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper, BinaryOperator<U> mergeFunction, Supplier<M> mapSupplier) Накопите элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам.
static <T> Collector<T,Set<T>>	toSet() Возвраты a Collector это накапливает входные элементы в новое Set.
static Collector<String,StringBuilder>	toStringBuilder() Возвраты a Collector это связывает входные элементы в новое StringBuilder.
static Collector<CharSequence,StringJoiner>	toStringJoiner(CharSequence delimiter) Возвраты a Collector это связывает входные элементы в новое StringJoiner, использование указанного разделителя.

Методы, наследованные от class java.lang. Объект

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Деталь метода

throwingMerger

public static <T> BinaryOperator<T> throwingMerger()

Возвращает функцию слияния, подходящую для использования в Map.merge() или toMap(), который всегда бросает IllegalStateException. Это может использоваться, чтобы осуществить предположение, что собираемые элементы отличны.

Введите Параметры:

T - тип входных параметров функции слияния

Возвраты:

функция слияния, которые всегда бросают IllegalStateException

См. Также:

firstWinsMerger(), lastWinsMerger()

firstWinsMerger

public static <T> BinaryOperator<T> firstWinsMerger()

Возвращает функцию слияния, подходящую для использования в Map.merge() или toMap(), который реализует "первые победы" политика.

Введите Параметры:

T - тип входных параметров функции слияния

Возвраты:

функция слияния, которая всегда возвращает ее первый параметр

См. Также:

lastWinsMerger(), throwingMerger()

lastWinsMerger

public static <T> BinaryOperator<T> lastWinsMerger()

Возвращает функцию слияния, подходящую для использования в Map.merge() или toMap(), который реализует "последние победы" политика.

Введите Параметры:

T - тип входных параметров функции слияния

Возвраты:

функция слияния, которая всегда возвращает ее второй параметр

См. Также:

firstWinsMerger(), throwingMerger()

toCollection

public static <T,C extends Collection<T>> Collector<T,C> toCollection(Supplier<C> collectionFactory)

Возвраты a Collector это накапливает входные элементы в новое Collection, во встречаются с порядком. Collection создается обеспеченной фабрикой.

Введите Параметры:

T - тип входных элементов

C - тип получающегося Collection

Параметры:

collectionFactory - a Supplier который возвращает новое, пустое Collection из соответствующего типа

Возвраты:

a Collector который собирает все входные элементы в a Collection, во встречаются с порядком

toList

public static <T> Collector<T,List<T>> toList()

Возвраты a Collector это накапливает входные элементы в новое List. Нет никаких гарантий на типе, переменчивости, сериализуемости, или потокобезопасности List возвращенный.

Введите Параметры:

T - тип входных элементов

Возвраты:

a Collector который собирает все входные элементы в a List, во встречаются с порядком

toSet

public static <T> Collector<T,Set<T>> toSet()

Возвраты a Collector это накапливает входные элементы в новое Set. Нет никаких гарантий на типе, переменчивости, сериализуемости, или потокобезопасности Set возвращенный.

Это unordered Коллектор.

Введите Параметры:

T - тип входных элементов

Возвраты:

a Collector который собирает все входные элементы в a Set

toStringBuilder

public static Collector<String,StringBuilder> toStringBuilder()

Возвраты a Collector это связывает входные элементы в новое StringBuilder.

Возвраты:

a Collector который собирает Строковые элементы в a StringBuilder, во встречаются с порядком

toStringJoiner

public static Collector<CharSequence,StringJoiner> toStringJoiner(CharSequence delimiter)

Возвраты a Collector это связывает входные элементы в новое StringJoiner, использование указанного разделителя.

Параметры:

delimiter - разделитель, который будет использоваться между каждым элементом

Возвраты:

A Collector который собирает Строковые элементы в a StringJoiner, во встречаются с порядком

отображение

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

Адаптирует a Collector<U,R> к a Collector<T,R> применяя отображающуюся функцию к каждому входному элементу перед накоплением.

Примечание API:

mapping() коллекторы являются самыми полезными когда использующийся в многоуровневом сокращении, нисходящем потоке groupingBy или partitioningBy. Например, учитывая поток Person, накапливать набор фамилий в каждом городе:

     Map<City, Set<String>> lastNamesByCity
         = people.stream().collect(groupingBy(Person::getCity,
                                              mapping(Person::getLastName, toSet())));
 

Введите Параметры:

T - тип входных элементов

U - тип элементов принимается нисходящим коллектором

R - тип результата коллектора

Параметры:

mapper - функция, которая будет применена к входным элементам

downstream - коллектор, который примет отображенные значения

Возвраты:

коллектор, который применяет отображающуюся функцию к входным элементам и обеспечивает отображенные результаты для нисходящего коллектора

подсчет

public static <T> Collector<T,Long> counting()

Возвраты a Collector<T, Long> это считает число входных элементов.

Требования реализации:

Это приводит к результату, эквивалентному:

     reducing(0L, e -> 1L, Long::sum)
 

Введите Параметры:

T - тип входных элементов

Возвраты:

a Collector это считает входные элементы

minBy

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

Возвраты a Collector<T, T> это производит минимальный элемент согласно данному Comparator.

Требования реализации:

Это приводит к результату, эквивалентному:

     reducing(Comparators.lesserOf(comparator))
 

Введите Параметры:

T - тип входных элементов

Параметры:

comparator - a Comparator для того, чтобы сравнить элементы

Возвраты:

a Collector это производит минимальное значение

maxBy

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

Возвраты a Collector<T, T> это производит максимальный элемент согласно данному Comparator.

Требования реализации:

Это приводит к результату, эквивалентному:

     reducing(Comparators.greaterOf(comparator))
 

Введите Параметры:

T - тип входных элементов

Параметры:

comparator - a Comparator для того, чтобы сравнить элементы

Возвраты:

a Collector это производит максимальное значение

sumBy

public static <T> Collector<T,Long> sumBy(Function<? super T,Long> mapper)

Возвраты a Collector<T, Long> это производит сумму долго оцененной функции, которой применяются к входной элемент.

Требования реализации:

Это приводит к результату, эквивалентному:

     reducing(0L, mapper, Long::sum)
 

Введите Параметры:

T - тип входных элементов

Параметры:

mapper - функция, извлекающая свойство, которое будет суммировано

Возвраты:

a Collector это производит сумму полученного свойства

сокращение

public static <T> Collector<T,T> reducing(T identity,
                                          BinaryOperator<T> op)

Возвраты a Collector<T,T> который выполняет сокращение его входных элементов под указанным BinaryOperator.

Примечание API:

reducing() коллекторы являются самыми полезными когда использующийся в многоуровневом сокращении, нисходящем потоке groupingBy или partitioningBy. Чтобы выполнить простое сокращение на потоке, использовать Stream.reduce(BinaryOperator) вместо этого.

Введите Параметры:

T - тип элемента для ввода и вывода сокращения

Параметры:

identity - значение идентификационных данных для сокращения (также, значение, которое возвращается, когда нет никаких входных элементов),

op - a BinaryOperator<T> используемый, чтобы уменьшить входные элементы

Возвраты:

a Collector который реализует работу сокращения

См. Также:

reducing(BinaryOperator), reducing(Object, Function, BinaryOperator)

сокращение

public static <T> Collector<T,T> reducing(BinaryOperator<T> op)

Возвраты a Collector<T,T> который выполняет сокращение его входных элементов под указанным BinaryOperator.

Примечание API:

reducing() коллекторы являются самыми полезными когда использующийся в многоуровневом сокращении, нисходящем потоке groupingBy или partitioningBy. Чтобы выполнить простое сокращение на потоке, использовать Stream.reduce(BinaryOperator) вместо этого.

Например, учитывая поток Person, вычислить самого высокого человека в каждом городе:

     Comparator<Person> byHeight = Comparators.comparing(Person::getHeight);
     BinaryOperator<Person> tallerOf = Comparators.greaterOf(byHeight);
     Map<City, Person> tallestByCity
         = people.stream().collect(groupingBy(Person::getCity, reducing(tallerOf)));
 

Требования реализации:

Реализация по умолчанию эквивалентна:

     reducing(null, op);
 

Введите Параметры:

T - тип элемента для ввода и вывода сокращения

Параметры:

op - a BinaryOperator<T> используемый, чтобы уменьшить входные элементы

Возвраты:

a Collector который реализует работу сокращения

См. Также:

reducing(Object, BinaryOperator), reducing(Object, Function, BinaryOperator)

сокращение

public static <T,U> Collector<T,U> reducing(U identity,
                                            Function<? super T,? extends U> mapper,
                                            BinaryOperator<U> op)

Возвраты a Collector<T,U> который выполняет сокращение его входных элементов под указанной функцией отображения и BinaryOperator. Это - обобщение reducing(Object, BinaryOperator) который позволяет преобразование элементов перед сокращением.

Примечание API:

reducing() коллекторы являются самыми полезными когда использующийся в многоуровневом сокращении, нисходящем потоке groupingBy или partitioningBy. Чтобы выполнить простое сокращение на потоке, использовать Stream.reduce(BinaryOperator) вместо этого.

Например, учитывая поток Person, вычислить самую длинную фамилию резидентных объектов в каждом городе:

     Comparator<String> byLength = Comparators.comparing(String::length);
     BinaryOperator<String> longerOf = Comparators.greaterOf(byLength);
     Map<City, String> longestLastNameByCity
         = people.stream().collect(groupingBy(Person::getCity,
                                              reducing(Person::getLastName, longerOf)));
 

Введите Параметры:

T - тип входных элементов

U - тип отображенных значений

Параметры:

identity - значение идентификационных данных для сокращения (также, значение, которое возвращается, когда нет никаких входных элементов),

mapper - отображающаяся функция, чтобы примениться к каждому входному значению

op - a BinaryOperator<U> используемый, чтобы уменьшить отображенные значения

Возвраты:

a Collector реализация карты - уменьшает работу

См. Также:

reducing(Object, BinaryOperator), reducing(BinaryOperator)

groupingBy

public static <T,K> Collector<T,Map<K,List<T>>> groupingBy(Function<? super T,? extends K> classifier)

Возвраты a Collector реализация "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации.

Функция классификации отображает элементы на некоторый ключевой тип K. Коллектор производит a Map<K, List<T>> чьи ключи являются значениями, следующими из применения функции классификации к входным элементам, и чьи соответствующие значения Lists содержащий входные элементы, которые отображаются на связанный ключ под функцией классификации.

Нет никаких гарантий на типе, переменчивости, сериализуемости, или потокобезопасности Map или List объекты возвратились.

Требования реализации:

Это приводит к результату, подобному:

     groupingBy(classifier, toList());
 

Введите Параметры:

T - тип входных элементов

K - тип ключей

Параметры:

classifier - функция классификатора отображение входных элементов к ключам

Возвраты:

a Collector реализация группы - работой

См. Также:

groupingBy(Function, Collector), groupingBy(Function, Supplier, Collector), groupingByConcurrent(Function)

groupingBy

public static <T,K,D> Collector<T,Map<K,D>> groupingBy(Function<? super T,? extends K> classifier,
                                                       Collector<? super T,D> downstream)

Возвраты a Collector реализация каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector.

Функция классификации отображает элементы на некоторый ключевой тип K. Нисходящий коллектор работает на элементах типа T и приводит к результату типа D. Получающийся коллектор производит a Map<K, D>.

Нет никаких гарантий на типе, переменчивости, сериализуемости, или потокобезопасности Map возвращенный.

Например, чтобы вычислить набор фамилий людей в каждом городе:

     Map<City, Set<String>> namesByCity
         = people.stream().collect(groupingBy(Person::getCity,
                                              mapping(Person::getLastName, toSet())));
 

Введите Параметры:

T - тип входных элементов

K - тип ключей

D - тип результата нисходящего сокращения

Параметры:

classifier - функция классификатора отображение входных элементов к ключам

downstream - a Collector реализация нисходящего сокращения

Возвраты:

a Collector реализация каскадной группы - работой

См. Также:

groupingBy(Function), groupingBy(Function, Supplier, Collector), groupingByConcurrent(Function, Collector)

groupingBy

public static <T,K,D,M extends Map<K,D>> Collector<T,M> groupingBy(Function<? super T,? extends K> classifier,
                                                                   Supplier<M> mapFactory,
                                                                   Collector<? super T,D> downstream)

Возвраты a Collector реализация каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector. Map произведенный Коллектором создается с предоставленной функцией фабрики.

Функция классификации отображает элементы на некоторый ключевой тип K. Нисходящий коллектор работает на элементах типа T и приводит к результату типа D. Получающийся коллектор производит a Map<K, D>.

Например, чтобы вычислить набор фамилий людей в каждом городе, где названия города сортируются:

     Map<City, Set<String>> namesByCity
         = people.stream().collect(groupingBy(Person::getCity, TreeMap::new,
                                              mapping(Person::getLastName, toSet())));
 

Введите Параметры:

T - тип входных элементов

K - тип ключей

D - тип результата нисходящего сокращения

M - тип получающегося Map

Параметры:

classifier - функция классификатора отображение входных элементов к ключам

downstream - a Collector реализация нисходящего сокращения

mapFactory - функция, которая, когда вызвано, производит новое пустое Map из требуемого типа

Возвраты:

a Collector реализация каскадной группы - работой

См. Также:

groupingBy(Function, Collector), groupingBy(Function), groupingByConcurrent(Function, Supplier, Collector)

groupingByConcurrent

public static <T,K> Collector<T,ConcurrentMap<K,List<T>>> groupingByConcurrent(Function<? super T,? extends K> classifier)

Возвраты a Collector реализация параллельной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации.

Это - a concurrent и unordered Коллектор.

Функция классификации отображает элементы на некоторый ключевой тип K. Коллектор производит a ConcurrentMap<K, List<T>> чьи ключи являются значениями, следующими из применения функции классификации к входным элементам, и чьи соответствующие значения Lists содержащий входные элементы, которые отображаются на связанный ключ под функцией классификации.

Нет никаких гарантий на типе, переменчивости, или сериализуемости Map или List объекты возвратились, или потокобезопасности List объекты возвратились.

Требования реализации:

Это приводит к результату, подобному:

     groupingByConcurrent(classifier, toList());
 

Введите Параметры:

T - тип входных элементов

K - тип ключей

Параметры:

classifier - функция классификатора отображение входных элементов к ключам

Возвраты:

a Collector реализация группы - работой

См. Также:

groupingBy(Function), groupingByConcurrent(Function, Collector), groupingByConcurrent(Function, Supplier, Collector)

groupingByConcurrent

public static <T,K,D> Collector<T,ConcurrentMap<K,D>> groupingByConcurrent(Function<? super T,? extends K> classifier,
                                                                           Collector<? super T,D> downstream)

Возвраты a Collector реализация параллельной каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector.

Это - a concurrent и unordered Коллектор.

Функция классификации отображает элементы на некоторый ключевой тип K. Нисходящий коллектор работает на элементах типа T и приводит к результату типа D. Получающийся коллектор производит a Map<K, D>.

Например, чтобы вычислить набор фамилий людей в каждом городе, где названия города сортируются:

     ConcurrentMap<City, Set<String>> namesByCity
         = people.stream().collect(groupingByConcurrent(Person::getCity, TreeMap::new,
                                                        mapping(Person::getLastName, toSet())));
 

Введите Параметры:

T - тип входных элементов

K - тип ключей

D - тип результата нисходящего сокращения

Параметры:

classifier - функция классификатора отображение входных элементов к ключам

downstream - a Collector реализация нисходящего сокращения

Возвраты:

a Collector реализация каскадной группы - работой

См. Также:

groupingBy(Function, Collector), groupingByConcurrent(Function), groupingByConcurrent(Function, Supplier, Collector)

groupingByConcurrent

public static <T,K,D,M extends ConcurrentMap<K,D>> Collector<T,M> groupingByConcurrent(Function<? super T,? extends K> classifier,
                                                                                       Supplier<M> mapFactory,
                                                                                       Collector<? super T,D> downstream)

Возвращает параллельное Collector реализация каскадной "группы" работой на входных элементах типа T, группировка элементов согласно функции классификации, и затем выполнения работы сокращения на значениях, связанных с данным ключом, используя указанный нисходящий поток Collector. ConcurrentMap произведенный Коллектором создается с предоставленной функцией фабрики.

Это - a concurrent и unordered Коллектор.

Функция классификации отображает элементы на некоторый ключевой тип K. Нисходящий коллектор работает на элементах типа T и приводит к результату типа D. Получающийся коллектор производит a Map<K, D>.

Например, чтобы вычислить набор фамилий людей в каждом городе, где названия города сортируются:

     ConcurrentMap<City, Set<String>> namesByCity
         = people.stream().collect(groupingBy(Person::getCity, ConcurrentSkipListMap::new,
                                              mapping(Person::getLastName, toSet())));
 

Введите Параметры:

T - тип входных элементов

K - тип ключей

D - тип результата нисходящего сокращения

M - тип получающегося ConcurrentMap

Параметры:

classifier - функция классификатора отображение входных элементов к ключам

downstream - a Collector реализация нисходящего сокращения

mapFactory - функция, которая, когда вызвано, производит новое пустое ConcurrentMap из требуемого типа

Возвраты:

a Collector реализация каскадной группы - работой

См. Также:

groupingByConcurrent(Function), groupingByConcurrent(Function, Collector), groupingBy(Function, Supplier, Collector)

partitioningBy

public static <T> Collector<T,Map<Boolean,List<T>>> partitioningBy(Predicate<? super T> predicate)

Возвраты a Collector который делит входные элементы согласно a Predicate, и организует их в a Map<Boolean, List<T>>. Нет никаких гарантий на типе, переменчивости, сериализуемости, или потокобезопасности Map возвращенный.

Введите Параметры:

T - тип входных элементов

Параметры:

predicate - предикат используется для того, чтобы классифицировать входные элементы

Возвраты:

a Collector реализация работы разделения

См. Также:

partitioningBy(Predicate, Collector)

partitioningBy

public static <T,D> Collector<T,Map<Boolean,D>> partitioningBy(Predicate<? super T> predicate,
                                                               Collector<? super T,D> downstream)

Возвраты a Collector который делит входные элементы согласно a Predicate, уменьшает значения в каждом разделе согласно другому Collector, и организует их в a Map<Boolean, D> чьи значения являются результатом нисходящего сокращения.

Нет никаких гарантий на типе, переменчивости, сериализуемости, или потокобезопасности Map возвращенный.

Введите Параметры:

T - тип входных элементов

D - тип результата нисходящего сокращения

Параметры:

predicate - предикат используется для того, чтобы классифицировать входные элементы

downstream - a Collector реализация нисходящего сокращения

Возвраты:

a Collector реализация каскадной работы разделения

См. Также:

partitioningBy(Predicate)

toMap

public static <T,K,U> Collector<T,Map<K,U>> toMap(Function<? super T,? extends K> keyMapper,
                                                  Function<? super T,? extends U> valueMapper)

Накопите элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам. Если отображенные ключи содержат копии (согласно Object.equals(Object)), IllegalStateException бросается, когда работа набора выполняется. Если у отображенных ключей могут быть копии, использовать toMap(Function, Function, BinaryOperator) вместо этого.

Примечание API:

Ключу или для значению свойственно быть входными элементами. В этом случае, служебный метод java.util.function.Function#identity() может быть полезным. Например, следующее производит a Map отображение студентов к их среднему баллу:

     Map<Student, Double> studentToGPA
         students.stream().collect(toMap(Functions.identity(),
                                         student -> computeGPA(student)));
 

И следующее производит a Map отображение уникального идентификатора студентам:

     Map<String, Student> studentIdToStudent
         students.stream().collect(toMap(Student::getId,
                                         Functions.identity());
 

Введите Параметры:

T - тип входных элементов

K - выходной тип ключевой функции отображения

U - выходной тип функции построения карты ценности

Параметры:

keyMapper - отображающаяся функция, чтобы произвести ключи

valueMapper - отображающаяся функция, чтобы произвести значения

Возвраты:

a Collector который собирает элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам

См. Также:

toMap(Function, Function, BinaryOperator), toMap(Function, Function, BinaryOperator, Supplier), toConcurrentMap(Function, Function)

toMap

public static <T,K,U> Collector<T,Map<K,U>> toMap(Function<? super T,? extends K> keyMapper,
                                                  Function<? super T,? extends U> valueMapper,
                                                  BinaryOperator<U> mergeFunction)

Накопите элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам. Если отображенные ключи содержат копии (согласно Object.equals(Object)), функция построения карты ценности применяется к каждому равному элементу, и результаты объединяются, используя обеспеченную функцию слияния.

Примечание API:

Есть многократные способы иметь дело с коллизиями между многократными элементами, отображающимися на тот же самый ключ. Есть некоторые предопределенные объединяющиеся функции, такой как throwingMerger(), firstWinsMerger(), и lastWinsMerger(), та реализация общая политика, или можно реализовать пользовательские политики легко. Например, если у Вас есть поток Person, и Вы хотите произвести "телефонную книгу", отображающую имя к адресу, но возможно, что у двух человек есть то же самое имя, можно сделать следующим образом к корректно соглашениям с этими коллизиями, и произвести a Map отображение имен к связанному списку адресов:

     Map<String, String> phoneBook
         people.stream().collect(toMap(Person::getName,
                                       Person::getAddress,
                                       (s, a) -> s + ", " + a));
 

Введите Параметры:

T - тип входных элементов

K - выходной тип ключевой функции отображения

U - выходной тип функции построения карты ценности

Параметры:

keyMapper - отображающаяся функция, чтобы произвести ключи

valueMapper - отображающаяся функция, чтобы произвести значения

mergeFunction - функция слияния, используемая, чтобы разрешить коллизии между значениями, связанными с тем же самым ключом, как предоставлено к Map.merge(Object, Object, BiFunction)

Возвраты:

a Collector который собирает элементы в a Map чьи ключи являются результатом применения ключевой функции отображения к входным элементам, и чьи значения являются результатом применения функции построения карты ценности ко всем входным элементам, равным ключу и объединению их использующий функцию слияния

См. Также:

toMap(Function, Function), toMap(Function, Function, BinaryOperator, Supplier), toConcurrentMap(Function, Function, BinaryOperator)

toMap

public static <T,K,U,M extends Map<K,U>> Collector<T,M> toMap(Function<? super T,? extends K> keyMapper,
                                                              Function<? super T,? extends U> valueMapper,
                                                              BinaryOperator<U> mergeFunction,
                                                              Supplier<M> mapSupplier)

Накопите элементы в a Map чьи ключи и значения являются результатом применения отображающихся функций к входным элементам. Если отображенные ключи содержат копии (согласно Object.equals(Object)), функция построения карты ценности применяется к каждому равному элементу, и результаты объединяются, используя обеспеченную функцию слияния. Map создается обеспеченной функцией поставщика.

Введите Параметры:

T - тип входных элементов

K - выходной тип ключевой функции отображения

U - выходной тип функции построения карты ценности

M - тип получающегося Map

Параметры:

keyMapper - отображающаяся функция, чтобы произвести ключи

valueMapper - отображающаяся функция, чтобы произвести значения

mergeFunction - функция слияния, используемая, чтобы разрешить коллизии между значениями, связанными с тем же самым ключом, как предоставлено к Map.merge(Object, Object, BiFunction)

mapSupplier - функция, которая возвращает новое, пустое Map в который будут вставлены результаты

Возвраты:

a Collector который собирает элементы в a Map чьи ключи являются результатом применения ключевой функции отображения к входным элементам, и чьи значения являются результатом применения функции построения карты ценности ко всем входным элементам, равным ключу и объединению их использующий функцию слияния

См. Также:

toMap(Function, Function), toMap(Function, Function, BinaryOperator), toConcurrentMap(Function, Function, BinaryOperator, Supplier)

toConcurrentMap

public static <T,K,U> Collector<T,ConcurrentMap<K,U>> toConcurrentMap(Function<? super T,? extends K> keyMapper,
                                                                      Function<? super T,? extends U> valueMapper)

Накопите элементы в a ConcurrentMap чьи ключи и значения являются результатом применения отображающихся функций к входным элементам. Если отображенные ключи содержат копии (согласно Object.equals(Object)), IllegalStateException бросается, когда работа набора выполняется. Если у отображенных ключей могут быть копии, использовать toConcurrentMap(Function, Function, BinaryOperator) вместо этого.

Примечание API:

Ключу или для значению свойственно быть входными элементами. В этом случае, служебный метод java.util.function.Function#identity() может быть полезным. Например, следующее производит a Map отображение студентов к их среднему баллу:

     Map<Student, Double> studentToGPA
         students.stream().collect(toMap(Functions.identity(),
                                         student -> computeGPA(student)));
 

И следующее производит a Map отображение уникального идентификатора студентам:

     Map<String, Student> studentIdToStudent
         students.stream().collect(toConcurrentMap(Student::getId,
                                                   Functions.identity());
 

Это - a concurrent и unordered Коллектор.

Введите Параметры:

T - тип входных элементов

K - выходной тип ключевой функции отображения

U - выходной тип функции построения карты ценности

Параметры:

keyMapper - отображающаяся функция, чтобы произвести ключи

valueMapper - отображающаяся функция, чтобы произвести значения

Возвраты:

параллельное Collector который собирает элементы в a ConcurrentMap чьи ключи являются результатом применения ключевой функции отображения к входным элементам, и чьи значения являются результатом применения функции построения карты ценности к входным элементам

См. Также:

toMap(Function, Function), toConcurrentMap(Function, Function, BinaryOperator), toConcurrentMap(Function, Function, BinaryOperator, Supplier)

toConcurrentMap

public static <T,K,U> Collector<T,ConcurrentMap<K,U>> toConcurrentMap(Function<? super T,? extends K> keyMapper,
                                                                      Function<? super T,? extends U> valueMapper,
                                                                      BinaryOperator<U> mergeFunction)

Накопите элементы в a ConcurrentMap чьи ключи и значения являются результатом применения отображающихся функций к входным элементам. Если отображенные ключи содержат копии (согласно Object.equals(Object)), функция построения карты ценности применяется к каждому равному элементу, и результаты объединяются, используя обеспеченную функцию слияния.

Примечание API:

Есть многократные способы иметь дело с коллизиями между многократными элементами, отображающимися на тот же самый ключ. Есть некоторые предопределенные объединяющиеся функции, такой как throwingMerger(), firstWinsMerger(), и lastWinsMerger(), та реализация общая политика, или можно реализовать пользовательские политики легко. Например, если у Вас есть поток Person, и Вы хотите произвести "телефонную книгу", отображающую имя к адресу, но возможно, что у двух человек есть то же самое имя, можно сделать следующим образом к корректно соглашениям с этими коллизиями, и произвести a Map отображение имен к связанному списку адресов:

     Map<String, String> phoneBook
         people.stream().collect(toConcurrentMap(Person::getName,
                                                 Person::getAddress,
                                                 (s, a) -> s + ", " + a));
 

Это - a concurrent и unordered Коллектор.

Введите Параметры:

T - тип входных элементов

K - выходной тип ключевой функции отображения

U - выходной тип функции построения карты ценности

Параметры:

keyMapper - отображающаяся функция, чтобы произвести ключи

valueMapper - отображающаяся функция, чтобы произвести значения

mergeFunction - функция слияния, используемая, чтобы разрешить коллизии между значениями, связанными с тем же самым ключом, как предоставлено к Map.merge(Object, Object, BiFunction)

Возвраты:

параллельное Collector который собирает элементы в a ConcurrentMap чьи ключи являются результатом применения ключевой функции отображения к входным элементам, и чьи значения являются результатом применения функции построения карты ценности ко всем входным элементам, равным ключу и объединению их использующий функцию слияния

См. Также:

toConcurrentMap(Function, Function), toConcurrentMap(Function, Function, BinaryOperator, Supplier), toMap(Function, Function, BinaryOperator)

toConcurrentMap

public static <T,K,U,M extends ConcurrentMap<K,U>> Collector<T,M> toConcurrentMap(Function<? super T,? extends K> keyMapper,
                                                                                  Function<? super T,? extends U> valueMapper,
                                                                                  BinaryOperator<U> mergeFunction,
                                                                                  Supplier<M> mapSupplier)

Накопите элементы в a ConcurrentMap чьи ключи и значения являются результатом применения отображающихся функций к входным элементам. Если отображенные ключи содержат копии (согласно Object.equals(Object)), функция построения карты ценности применяется к каждому равному элементу, и результаты объединяются, используя обеспеченную функцию слияния. ConcurrentMap создается обеспеченной функцией поставщика.

Это - a concurrent и unordered Коллектор.

Введите Параметры:

T - тип входных элементов

K - выходной тип ключевой функции отображения

U - выходной тип функции построения карты ценности

M - тип получающегося ConcurrentMap

Параметры:

keyMapper - отображающаяся функция, чтобы произвести ключи

valueMapper - отображающаяся функция, чтобы произвести значения

mergeFunction - функция слияния, используемая, чтобы разрешить коллизии между значениями, связанными с тем же самым ключом, как предоставлено к Map.merge(Object, Object, BiFunction)

mapSupplier - функция, которая возвращает новое, пустое Map в который будут вставлены результаты

Возвраты:

параллельное Collector который собирает элементы в a ConcurrentMap чьи ключи являются результатом применения ключевой функции отображения к входным элементам, и чьи значения являются результатом применения функции построения карты ценности ко всем входным элементам, равным ключу и объединению их использующий функцию слияния

См. Также:

toConcurrentMap(Function, Function), toConcurrentMap(Function, Function, BinaryOperator), toMap(Function, Function, BinaryOperator, Supplier)

toIntSummaryStatistics

public static <T> Collector<T,IntSummaryStatistics> toIntSummaryStatistics(ToIntFunction<? super T> mapper)

Возвраты a Collector который применяется int- производящий отображающий функцию на каждый входной элемент, и сводную статистику возвратов для получающихся значений.

Введите Параметры:

T - тип входных элементов

Параметры:

mapper - отображающаяся функция, чтобы примениться к каждому элементу

Возвраты:

a Collector реализация сокращения сводной статистики

См. Также:

toDoubleSummaryStatistics(ToDoubleFunction), toLongSummaryStatistics(ToLongFunction)

toLongSummaryStatistics

public static <T> Collector<T,LongSummaryStatistics> toLongSummaryStatistics(ToLongFunction<? super T> mapper)

Возвраты a Collector который применяется long- производящий отображающий функцию на каждый входной элемент, и сводную статистику возвратов для получающихся значений.

Введите Параметры:

T - тип входных элементов

Параметры:

mapper - отображающаяся функция, чтобы примениться к каждому элементу

Возвраты:

a Collector реализация сокращения сводной статистики

См. Также:

toDoubleSummaryStatistics(ToDoubleFunction), toIntSummaryStatistics(ToIntFunction)

toDoubleSummaryStatistics

public static <T> Collector<T,DoubleSummaryStatistics> toDoubleSummaryStatistics(ToDoubleFunction<? super T> mapper)

Возвраты a Collector который применяется double- производящий отображающий функцию на каждый входной элемент, и сводную статистику возвратов для получающихся значений.

Введите Параметры:

T - тип входных элементов

Параметры:

mapper - отображающаяся функция, чтобы примениться к каждому элементу

Возвраты:

a Collector реализация сокращения сводной статистики

См. Также:

toLongSummaryStatistics(ToLongFunction), toIntSummaryStatistics(ToIntFunction)