Коллекторы и группировка в Java

users.stream().collect(toMap(User::email, u -> u));
// IllegalStateException: Duplicate key а
//   (attempted merging values аня and антон)

users.stream().collect(toMap(User::email, u -> u, (a, b) -> b));  // побеждает последний

Проверьте себя

Пять вопросов из банка по этой подтеме. Всего их 20, остальные разбираются в тренажёре.

1. #collectors_grouping1 / 5
   Что произойдёт при Collectors.toMap с двумя элементами, дающими одинаковый ключ?

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

   B)Оба значения автоматически сложатся в список, и по ключу будет храниться List из двух элементов

   C)IllegalStateException (duplicate key), если не задать функцию слияния

   D)Первый элемент останется, а второй будет тихо отброшен без какого-либо исключения или сообщения

   показать ответ и разбор

   +C)IllegalStateException (duplicate key), если не задать функцию слияния

   // разбор: toMap(keyFn, valueFn) с ДВУМЯ элементами, дающими один ключ, бросает IllegalStateException: Duplicate key — это защита от незаметной потери данных. Чтобы разрешить конфликт, передают третий аргумент — mergeFunction (например, (a, b) -> b — взять последнее, или a + b — сложить). Если по смыслу нужен список значений на ключ — берут groupingBy, а не toMap. Забытый merge — классическая причина падения при, казалось бы, безобидной сборке в карту.

2. #collectors_grouping2 / 5
   Что делает Collectors.joining(", ", "[", "]")?

   A)Разбивает каждую строку по запятой и собирает получившиеся части в один общий плоский список

   B)Соединяет элементы, но только если каждый заключён в квадратные скобки, иначе пропускает его

   C)Оборачивает каждый элемент в скобки по отдельности и возвращает список таких обёрнутых строк

   D)Склеивает строки через разделитель с префиксом и суффиксом

   показать ответ и разбор

   +D)Склеивает строки через разделитель с префиксом и суффиксом

   // разбор: joining(delimiter, prefix, suffix) сводит стрим строк (CharSequence) в ОДНУ строку: между элементами — разделитель, в начале — префикс, в конце — суффикс. Например, элементы a,b,c → "[a, b, c]". Есть варианты без аргументов (просто конкатенация) и только с разделителем. Под капотом использует StringBuilder — эффективно, в отличие от ручной склейки в reduce. Частый способ собрать человекочитаемое представление или CSV-строку из стрима.

3. #collectors_grouping3 / 5
   Зачем нужен downstream-коллектор во втором аргументе groupingBy?

   A)Задать, как агрегировать элементы внутри каждой группы (счёт, сумма, mapping)

   B)Чтобы отсортировать сами группы по ключу перед тем, как вернуть итоговую карту результата

   C)Чтобы ограничить число групп в результирующей карте заданным сверху числом самых крупных групп

   D)Чтобы задать тип возвращаемой карты (HashMap или TreeMap); на содержимое групп он не влияет

   показать ответ и разбор

   +A)Задать, как агрегировать элементы внутри каждой группы (счёт, сумма, mapping)

   // разбор: У groupingBy есть форма (classifier, downstream): downstream-коллектор говорит, ЧТО делать со значениями внутри каждой группы вместо сборки в List по умолчанию. Так одной строкой считают: counting() — число в группе; summingInt/averagingDouble — сумму/среднее; mapping(f, toList()) — преобразованные значения; maxBy/minBy; reducing(...). Downstream можно вкладывать (группировка внутри группировки). Это превращает стримы в мощный инструмент агрегаций, близкий к SQL GROUP BY с агрегатными функциями.

4. #collectors_grouping4 / 5
   Чем partitioningBy отличается от groupingBy?

   A)PartitioningBy делит стрим на произвольное число групп по значению, как и groupingBy, отличий по сути нет

   B)Делит ровно на две группы по предикату (ключи true/false)

   C)PartitioningBy случайным образом распределяет элементы по нескольким разделам для параллельной обработки

   D)PartitioningBy сортирует элементы на две половины по медиане, а groupingBy группирует по равенству ключа

   показать ответ и разбор

   +B)Делит ровно на две группы по предикату (ключи true/false)

   // разбор: partitioningBy(predicate) — частный случай группировки на ДВЕ группы по булеву условию: возвращает Map<Boolean, List<T>> с ГАРАНТИРОВАННО присутствующими ключами true и false (даже если одна группа пуста — там пустой список). groupingBy делит на произвольное число групп по значению классификатора и ключ есть только для встретившихся значений. Когда нужно «прошедшие/непрошедшие проверку» — partitioningBy читаемее и предсказуемее (оба ключа всегда есть), плюс поддерживает downstream.

5. #collectors_grouping5 / 5
   Чем reduce отличается от collect как способ сведения стрима?

   A)Reduce работает только с числами, а collect — только с объектами, поэтому они не пересекаются

   B)Collect можно применять лишь к последовательным стримам, а reduce — только к параллельным

   C)reduce сворачивает в одно неизменяемое значение; collect накапливает в изменяемый контейнер

   D)Reduce и collect эквивалентны и взаимозаменяемы без разницы в эффективности

   показать ответ и разбор

   +C)reduce сворачивает в одно неизменяемое значение; collect накапливает в изменяемый контейнер

   // разбор: reduce выполняет ИММУТАБЕЛЬНУЮ свёртку: комбинирует элементы в одно значение бинарной операцией (сумма, произведение, max) — каждый шаг возвращает новое значение. collect — MUTABLE reduction: накапливает элементы в ИЗМЕНЯЕМЫЙ контейнер (List, Map, StringBuilder) через supplier/accumulator/combiner, что эффективнее для «строящихся» структур (иначе reduce плодил бы новые контейнеры на каждый шаг — квадратично). Правило: одно значение → reduce; коллекция/строка → collect.