Класс 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() наиболее полезны при использовании в многоуровневой редукции, например, как нисходящий Collector для groupingBy или partitioningBy. Например, если дан поток Person, чтобы накопить множество фамилий в каждом городе:

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

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

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

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

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

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

Параметры:

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

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

Возвращает:

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

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() наиболее полезны при использовании в многоуровневой редукции, например, как нисходящий Collector для groupingBy или partitioningBy. Например, если дан поток Order, чтобы накопить набор позиций заказа для каждого покупателя:

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

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

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

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

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

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

Параметры:

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

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

Возвращает:

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

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

9

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

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

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

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

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

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

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

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

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

Параметры:

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

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

Возвращает:

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

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

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 — промежуточный тип накопления нисходящего Collector

R — тип результата нисходящего Collector

RR — тип результата создаваемого Collector

Параметры:

downstream — Collector

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

Возвращает:

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

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. Для выполнения простой операции map-reduce над потоком используйте вместо этого 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, реализующий операцию map-reduce

См. также:

• 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 работает, объединяя ключи одной карты с другой, что может быть затратной операцией. Если сохранять порядок появления элементов в результирующем Collector 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:

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

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

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:

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

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

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