Класс Collectors

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

Параметры типа:

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

C — тип результирующей Collection

Параметры:

collectionFactory — поставщик, предоставляющий новую пустую Collection, в которую будут добавлены результаты

Возвращает:

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

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

Параметры типа:

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

Возвращает:

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

public static <T> Collector<T,?,List<T>> toUnmodifiableList()

Параметры типа:

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

Возвращает:

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

С версии:

10

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

Параметры типа:

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

Возвращает:

Collector, собирающий все входные элементы в Set

public static <T> Collector<T,?,Set<T>> toUnmodifiableSet()

Параметры типа:

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

Возвращает:

Collector, накапливающий входные элементы в неизменяемый Set

С версии:

10

public static Collector<CharSequence, ?, String> joining()

Возвращает:

Collector, объединяющий входные элементы в String в порядке следования

public static Collector<CharSequence, ?, String> joining(CharSequence delimiter)

Параметры:

delimiter — разделитель, используемый между элементами

Возвращает:

Collector, объединяющий элементы CharSequence в порядке следования и разделяющий их указанным разделителем

public static Collector<CharSequence, ?, String> joining(CharSequence delimiter, CharSequence prefix, CharSequence suffix)

Параметры:

delimiter — разделитель, используемый между элементами

prefix — последовательность символов, добавляемая в начало объединённого результата

suffix — последовательность символов, добавляемая в конец объединённого результата

Возвращает:

Collector, объединяющий элементы CharSequence в порядке следования и разделяющий их указанным разделителем

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

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

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

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

Параметры типа:

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

U — тип элементов, принимаемых последующим коллектором

A — промежуточный тип накопления последующего коллектора

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

Параметры:

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

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

Возвращает:

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

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

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

Коллекторы flatMapping() наиболее полезны при использовании в многоуровневом свёртывании, например в качестве последующего коллектора для groupingBy или partitioningBy. Например, для потока Order, чтобы накопить набор позиций заказа каждого клиента:

Map<String, Set<LineItem>> itemsByCustomerName
  = orders.stream().collect(
    groupingBy(Order::getCustomerName,
               flatMapping(order -> order.getLineItems().stream(),
                           toSet())));

Параметры типа:

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

U — тип элементов, принимаемых последующим коллектором

A — промежуточный тип накопления последующего коллектора

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

Параметры:

mapper — функция, применяемая к входным элементам и возвращающая поток результатов

downstream — коллектор, принимающий элементы потока, возвращённого mapper

Возвращает:

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

С версии:

9

public static <T,A,R> Collector<T,?,R> filtering(Predicate<? super T> predicate, Collector<? super T, A, R> downstream)

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

Коллекторы filtering() наиболее полезны при использовании в многоуровневом свёртывании, например в качестве последующего коллектора для groupingBy или partitioningBy. Например, для потока Employee, чтобы накопить сотрудников каждого отдела, чья зарплата превышает заданный порог:

Map<Department, Set<Employee>> wellPaidEmployeesByDepartment
  = employees.stream().collect(
    groupingBy(Employee::getDepartment,
               filtering(e -> e.getSalary() > 2000,
                         toSet())));

Коллектор фильтрации отличается от операции filter() потока. Предположим, в этом примере в некотором отделе нет сотрудников, чья зарплата превышает порог. Использование показанного выше коллектора фильтрации приведёт к тому, что этот отдел будет сопоставлен с пустым Set. Если вместо этого выполнить операцию filter() потока, для этого отдела соответствия не будет.

Параметры типа:

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

A — промежуточный тип накопления последующего коллектора

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

Параметры:

predicate — предикат, применяемый к входным элементам

downstream — коллектор, принимающий значения, соответствующие предикату

Возвращает:

коллектор, применяющий предикат к входным элементам и передающий соответствующие ему элементы последующему коллектору

С версии:

9

public static <T,A,R,RR> Collector<T,A,RR> collectingAndThen(Collector<T,A,R> downstream, Function<R,RR> finisher)

List<String> list = people.stream().collect(
  collectingAndThen(toList(),
                    Collections::unmodifiableList));

Параметры типа:

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

A — промежуточный тип накопления последующего коллектора

R — тип результата последующего коллектора

RR — тип результата результирующего коллектора

Параметры:

downstream — коллектор

finisher — функция, применяемая к конечному результату последующего коллектора

Возвращает:

коллектор, выполняющий действие последующего коллектора, а затем дополнительный завершающий этап

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

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

Результат эквивалентен следующему:

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

Параметры типа:

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

Возвращает:

Collector, подсчитывающий входные элементы

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

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

Результат эквивалентен следующему:

    reducing(BinaryOperator.minBy(comparator))

Параметры типа:

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

Параметры:

comparator — Comparator для сравнения элементов

Возвращает:

Collector, возвращающий минимальное значение

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

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

Результат эквивалентен следующему:

    reducing(BinaryOperator.maxBy(comparator))

Параметры типа:

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

Параметры:

comparator — Comparator для сравнения элементов

Возвращает:

Collector, возвращающий максимальное значение

public static <T> Collector<T,?,Integer> summingInt(ToIntFunction<? super T> mapper)

Параметры типа:

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

Параметры:

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

Возвращает:

Collector, вычисляющий сумму производного свойства

public static <T> Collector<T,?,Long> summingLong(ToLongFunction<? super T> mapper)

Параметры типа:

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

Параметры:

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

Возвращает:

Collector, вычисляющий сумму производного свойства

public static <T> Collector<T,?,Double> summingDouble(ToDoubleFunction<? super T> mapper)

Параметры типа:

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

Параметры:

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

Возвращает:

Collector, вычисляющий сумму производного свойства

public static <T> Collector<T,?,Double> averagingInt(ToIntFunction<? super T> mapper)

Параметры типа:

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

Параметры:

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

Возвращает:

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

public static <T> Collector<T,?,Double> averagingLong(ToLongFunction<? super T> mapper)

Параметры типа:

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

Параметры:

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

Возвращает:

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

public static <T> Collector<T,?,Double> averagingDouble(ToDoubleFunction<? super T> mapper)

Примечание по реализации:

Формат double позволяет представить все последовательные целые числа в диапазоне от -2⁵³ до 2⁵³. Если конвейер содержит более 2⁵³ значений, делитель при вычислении среднего будет ограничен значением 2⁵³, что приведёт к дополнительным численным ошибкам.

Параметры типа:

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

Параметры:

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

Возвращает:

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

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

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

Коллекторы reducing() наиболее полезны при использовании в многоуровневом свёртывании, после groupingBy или partitioningBy. Для простого свёртывания потока используйте вместо этого Stream.reduce(Object, BinaryOperator).

Параметры типа:

T — тип элементов на входе и выходе свёртывания

Параметры:

identity — начальное значение свёртывания (оно же значение, возвращаемое при отсутствии входных элементов)

op — BinaryOperator<T>, используемый для свёртывания входных элементов

Возвращает:

Collector, реализующий операцию свёртывания

См. также:

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

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

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

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

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

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

Параметры типа:

T — тип элементов на входе и выходе свёртывания

Параметры:

op — BinaryOperator<T>, используемый для свёртывания входных элементов

Возвращает:

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)

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

Коллекторы reducing() наиболее полезны при использовании в многоуровневом свёртывании, после groupingBy или partitioningBy. Для простого отображения с последующим свёртыванием потока используйте вместо этого Stream.map(Function) и Stream.reduce(Object, BinaryOperator).

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

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

Параметры типа:

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

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

Параметры:

identity — начальное значение свёртывания (оно же значение, возвращаемое при отсутствии входных элементов)

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

op — BinaryOperator<U>, используемый для свёртывания отображённых значений

Возвращает:

Collector, реализующий операцию отображения с последующим свёртыванием

См. также:

• reducing(Object, BinaryOperator)
• reducing(BinaryOperator)

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

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

Результат аналогичен следующему:

    groupingBy(classifier, toList());

Примечание по реализации:

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

Параметры типа:

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

K — тип ключей

Параметры:

classifier — функция классификации, сопоставляющая входные элементы ключам

Возвращает:

Collector, реализующий операцию группировки

См. также:

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

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

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

Примечание по реализации:

Возвращаемый Collector не является конкурентным. В конвейерах параллельных потоков функция combiner выполняет слияние ключей одной карты с другой, что может быть затратной операцией. Если сохранять порядок передачи элементов последующему коллектору не требуется, использование groupingByConcurrent(Function, Collector) может обеспечить более высокую производительность при параллельной обработке.

Параметры типа:

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

K — тип ключей

A — промежуточный тип накопления последующего коллектора

D — тип результата последующей редукции

Параметры:

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

downstream — Collector, реализующий последующую редукцию

Возвращает:

Collector, реализующий каскадную операцию группировки

См. также:

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

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

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

Примечание по реализации:

Возвращаемый Collector не является конкурентным. В конвейерах параллельных потоков функция combiner выполняет слияние ключей одной карты с другой, что может быть затратной операцией. Если сохранять порядок передачи элементов последующему коллектору не требуется, использование groupingByConcurrent(Function, Supplier, Collector) может обеспечить более высокую производительность при параллельной обработке.

Параметры типа:

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

K — тип ключей

D — тип результата последующей редукции

A — промежуточный тип накопления последующего коллектора

M — тип результирующего Map

Параметры:

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

mapFactory — поставщик нового пустого Map, в который будут помещены результаты

downstream — Collector, реализующий последующую редукцию

Возвращает:

Collector, реализующий каскадную операцию группировки

См. также:

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

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

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

Результат аналогичен следующему:

    groupingByConcurrent(classifier, toList());

Параметры типа:

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

K — тип ключей

Параметры:

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

Возвращает:

конкурентный неупорядоченный Collector, реализующий операцию группировки

См. также:

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

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

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

Параметры типа:

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

K — тип ключей

A — промежуточный тип накопления последующего коллектора

D — тип результата последующей редукции

Параметры:

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

downstream — Collector, реализующий последующую редукцию

Возвращает:

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

См. также:

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

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

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

Параметры типа:

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

K — тип ключей

A — промежуточный тип накопления последующего коллектора

D — тип результата последующей редукции

M — тип результирующего ConcurrentMap

Параметры:

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

mapFactory — поставщик нового пустого ConcurrentMap, в который будут помещены результаты

downstream — Collector, реализующий последующую редукцию

Возвращает:

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

См. также:

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

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

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

Если раздел не содержит элементов, его значением в результирующей Map будет пустой List.

Параметры типа:

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

Параметры:

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

Возвращает:

Collector, реализующий операцию разделения

См. также:

• partitioningBy(Predicate, Collector)

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

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

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

Параметры типа:

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

D — тип результата последующей редукции

A — промежуточный тип накопления последующего коллектора

Параметры:

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

downstream — Collector, реализующий последующую редукцию

Возвращает:

Collector, реализующий каскадную операцию разделения

См. также:

• partitioningBy(Predicate)

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

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

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

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

А следующий код создает Map, сопоставляющую уникальный идентификатор студентам:

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

Примечание по реализации:

Возвращаемый Collector не является конкурентным. В конвейерах параллельных потоков функция combiner выполняет слияние ключей одной карты с другой, что может быть затратной операцией. Если не требуется, чтобы результаты добавлялись в Map в порядке встречи, использование toConcurrentMap(Function, Function) может обеспечить более высокую производительность при параллельной обработке.

Параметры типа:

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

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

U — выходной тип функции отображения значения

Параметры:

keyMapper — функция отображения для получения ключей

valueMapper — функция отображения для получения значений

Возвращает:

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

См. также:

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

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

Параметры типа:

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

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

U — выходной тип функции отображения значения

Параметры:

keyMapper — функция отображения для получения ключей; не должна быть null

valueMapper — функция отображения для получения значений; не должна быть null

Возвращает:

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

Выбрасывает:

NullPointerException — если keyMapper или valueMapper равен null

Начиная с версии:

10

См. также:

• toUnmodifiableMap(Function, Function, BinaryOperator)

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)

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

Существует несколько способов обработать ситуацию, когда несколько элементов отображаются в один и тот же ключ. В других вариантах toMap просто используется функция слияния, которая всегда выбрасывает исключение, но можно легко задать более гибкие правила слияния. Например, если у вас есть поток Person и вы хотите создать «телефонный справочник», сопоставляющий имена адресам, но у двух людей может быть одинаковое имя, можно корректно обработать такие совпадения следующим образом и создать Map, сопоставляющую именам объединенный список адресов:

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

Примечание по реализации:

Возвращаемый Collector не является конкурентным. В конвейерах параллельных потоков функция combiner выполняет слияние ключей одной карты с другой, что может быть затратной операцией. Если не требуется объединять результаты в Map в порядке встречи, использование toConcurrentMap(Function, Function, BinaryOperator) может обеспечить более высокую производительность при параллельной обработке.

Параметры типа:

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

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

U — выходной тип функции отображения значения

Параметры:

keyMapper — функция отображения для получения ключей

valueMapper — функция отображения для получения значений

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

Возвращает:

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

См. также:

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

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

Параметры типа:

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

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

U — выходной тип функции отображения значения

Параметры:

keyMapper — функция отображения для получения ключей; не должна быть null

valueMapper — функция отображения для получения значений; не должна быть null

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

Возвращает:

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

Выбрасывает:

NullPointerException — если keyMapper, valueMapper или mergeFunction равен null

Начиная с версии:

10

См. также:

• toUnmodifiableMap(Function, Function)

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> mapFactory)

Примечание по реализации:

Возвращаемый Collector не является потокобезопасным. Для конвейеров параллельных потоков функция combiner работает, объединяя ключи одной карты с другой, что может быть затратной операцией. Если результаты не требуется объединять в Map в порядке встречи, использование toConcurrentMap(Function, Function, BinaryOperator, Supplier) может обеспечить более высокую производительность при параллельной обработке.

Параметры типа:

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

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

U — выходной тип функции отображения значений

M — тип результирующего Map

Параметры:

keyMapper — функция отображения для получения ключей

valueMapper — функция отображения для получения значений

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

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

Возвращает:

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

См. также:

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

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

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

Часто входные элементы используются в качестве ключа или значения. В этом случае может быть полезен вспомогательный метод Function.identity(). Например, следующий код создаёт ConcurrentMap, сопоставляющую студентам их средний балл:

ConcurrentMap<Student, Double> studentToGPA
  = students.stream().collect(
    toConcurrentMap(Function.identity(),
                    student -> computeGPA(student)));

А следующий код создаёт ConcurrentMap, сопоставляющую уникальные идентификаторы студентам:

ConcurrentMap<String, Student> studentIdToStudent
  = students.stream().collect(
    toConcurrentMap(Student::getId,
                    Function.identity()));

Это сборщик с характеристиками concurrent и unordered.

Параметры типа:

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

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

U — выходной тип функции отображения значений

Параметры:

keyMapper — функция отображения для получения ключей

valueMapper — функция отображения для получения значений

Возвращает:

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

См. также:

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

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)

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

Существует несколько способов обработки конфликтов, возникающих, когда несколько элементов отображаются в один и тот же ключ. В других вариантах toConcurrentMap просто используется функция слияния, которая всегда выбрасывает исключение, однако можно легко реализовать более гибкие правила слияния. Например, если у вас есть поток Person и вы хотите создать «телефонную книгу», сопоставляющую имена адресам, но возможно, что у двух людей одинаковые имена, можно поступить следующим образом, чтобы корректно обработать такие конфликты и создать ConcurrentMap, сопоставляющую имена объединённому списку адресов:

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

Это сборщик с характеристиками concurrent и unordered.

Параметры типа:

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

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

U — выходной тип функции отображения значений

Параметры:

keyMapper — функция отображения для получения ключей

valueMapper — функция отображения для получения значений

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

Возвращает:

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

См. также:

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

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> mapFactory)

Параметры типа:

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

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

U — выходной тип функции отображения значений

M — тип результирующего ConcurrentMap

Параметры:

keyMapper — функция отображения для получения ключей

valueMapper — функция отображения для получения значений

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

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

Возвращает:

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

См. также:

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

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

Параметры типа:

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

Параметры:

mapper — функция отображения, применяемая к каждому элементу

Возвращает:

Collector, выполняющий редукцию для вычисления сводной статистики

См. также:

• summarizingDouble(ToDoubleFunction)
• summarizingLong(ToLongFunction)

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

Параметры типа:

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

Параметры:

mapper — функция отображения, применяемая к каждому элементу

Возвращает:

Collector, выполняющий редукцию для вычисления сводной статистики

См. также:

• summarizingDouble(ToDoubleFunction)
• summarizingInt(ToIntFunction)

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

Параметры типа:

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

Параметры:

mapper — функция отображения, применяемая к каждому элементу

Возвращает:

Collector, выполняющий редукцию для вычисления сводной статистики

См. также:

• summarizingLong(ToLongFunction)
• summarizingInt(ToIntFunction)

public static <T,R1,R2,R> Collector<T,?,R> teeing(Collector<? super T, ?, R1> downstream1, Collector<? super T, ?, R2> downstream2, BiFunction<? super R1, ? super R2, R> merger)

Параметры типа:

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

R1 — тип результата первого сборщика

R2 — тип результата второго сборщика

R — тип итогового результата

Параметры:

downstream1 — первый нижестоящий сборщик

downstream2 — второй нижестоящий сборщик

merger — функция, объединяющая два результата в один

Возвращает:

Collector, агрегирующий результаты двух предоставленных сборщиков.

Начиная с версии:

12