compact1, compact2, compact3

java.util.stream

Коллектор интерфейса <T, R>

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

T - тип входного элемента к собрать работе

R - тип результата собрать работы

public interface Collector<T,R>

Работа сокращения, которая поддерживает входные элементы сворачивания в совокупный результат. Результат может быть значением или может быть изменчивым контейнером результата. Примеры операций, накапливающих результаты в изменчивый контейнер результата, включают: накопление входных элементов в a Collection; конкатенация строк в a StringBuilder; вычислительная информация о сводке об элементах, таких как сумма, минута, максимальная, или средний; вычисления сводок "сводной таблицы", таких как "максимальная оцененная транзакция продавцом", и т.д. операции Сокращения могут быть выполнены или последовательно или параллельно.

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

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

     // Accumulate elements into a TreeSet
     Set<String> list = stream.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);

 

A Collector определяется тремя функциями, которые сотрудничают, чтобы управлять контейнером результата или результата. Они: создание начального результата, включая новый элемент данных в результат, и комбинируя два результата в одного. Последняя функция - объединение двух результатов в один - используется во время параллельных операций, где подмножества ввода накапливаются параллельно, и затем подрезультаты, объединенные в объединенный результат. Результатом может быть изменчивый контейнер или значение. Если результат изменчив, накопление и функции комбинации могут или видоизменить их левый параметр и возврат, что (такие как добавляющие элементы к набору), или возвращают новый результат, когда это не должно выполнить мутацию.

У коллекторов также есть ряд характеристик, включая Collector.Characteristics.CONCURRENT и Collector.Characteristics.STRICTLY_MUTATIVE. Эти характеристики обеспечивают подсказки, которые могут использоваться реализацией сокращения, чтобы обеспечить лучшую производительность.

Библиотеки, которые реализуют сокращение, основанное на Collector, такой как Stream.collect(Collector), должен придерживаться следующих ограничений:

• Первым параметром, который передают к функции аккумулятора, и обоим параметрам, которые передают к функции объединителя, должен быть результат предыдущего вызова resultSupplier(), accumulator(), или combiner().
• Реализация ничего не должна сделать с результатом любого поставщика результата, аккумулятора, или функций объединителя кроме передать их снова к аккумулятору или функциям объединителя, или возвратить их вызывающей стороне работы сокращения.
• Если результат передают к аккумулятору или функции объединителя, и тот же самый объект не возвращается из той функции, это никогда не используется снова.
• Как только результат передают к функции объединителя, его никогда не передают к функции аккумулятора снова.
• Для непараллельных коллекторов должен быть последовательно ограничен потоком любой результат, возвращенный от поставщика результата, аккумулятора, или функций объединителя. Это позволяет набору произойти параллельно без Collector будучи должен реализовать любую дополнительную синхронизацию. Реализация сокращения должна управлять этим, ввод должным образом делится, что разделы обрабатываются в изоляции, и объединение происходит только после того, как накопление полно.
• Для параллельных коллекторов реализация свободна к (но не требуемая к) сокращение реализации одновременно. Параллельное сокращение является тем, где функция аккумулятора вызывается одновременно от многократных потоков, используя тот же самый одновременно поддающийся изменению контейнер результата, вместо того, чтобы сохранить результат изолированным во время накопления. Параллельное сокращение должно только быть применено, если коллектор имеет Collector.Characteristics.UNORDERED характеристики или если инициирующие данные неупорядочиваются.

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

Выполнение работы сокращения с a Collector должен привести к результату, эквивалентному:

     BiFunction<R,T,R> accumulator = collector.accumulator();
     R result = collector.resultSupplier().get();
     for (T t : data)
         result = accumulator.apply(result, t);
     return result;
 

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

Пример работы, которая может быть легко смоделирована Collector накапливает элементы в a TreeSet. В этом случае, resultSupplier() функция () -> new Treeset<T>(), accumulator функция (set, element) -> { set.add(element); return set; }, и функция объединителя (left, right) -> { left.addAll(right); return left; }. (Это поведение реализуется Collectors.toCollection(TreeSet::new)). Ассоциативность TODO и коммутативность

С тех пор:

1.8

См. Также:

Stream.collect(Collector), Collectors

Вложенная Сводка Класса

Вложенные Классы

Модификатор и Тип	Интерфейс и Описание
static class	Коллектор. Характеристики Характеристики, указывающие на свойства a Collector, который может использоваться, чтобы оптимизировать реализации сокращения.

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

Модификатор и Тип	Метод и Описание
BiFunction<R,T,R>	accumulator() Функция, которая сворачивает новое значение в совокупный результат.
Set<Collector.Characteristics>	characteristics() Возвраты a Set из Collector.Characteristics указание на характеристики этого Коллектора.
BinaryOperator<R>	combiner() Функция, которая принимает два частичных результата и объединяет их.
Supplier<R>	resultSupplier() Функция, которая создает и возвращает новый результат, который не представляет "значений".

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

resultSupplier

Supplier<R> resultSupplier()

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

Возвраты:

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

аккумулятор

BiFunction<R,T,R> accumulator()

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

Если коллектор имеет Collector.Characteristics.STRICTLY_MUTATIVE характеристика, тогда функция аккумулятора должна всегда возвращать свой первый параметр после возможного видоизменения ее состояния.

Возвраты:

функция, которая сворачивает новое значение в совокупный результат

объединитель

BinaryOperator<R> combiner()

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

Если коллектор имеет Collector.Characteristics.STRICTLY_MUTATIVE характеристика, тогда функция объединителя должна всегда возвращать свой первый параметр после возможного видоизменения ее состояния.

Возвраты:

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

характеристики

Set<Collector.Characteristics> characteristics()

Возвраты a Set из Collector.Characteristics указание на характеристики этого Коллектора. Этот набор должен быть неизменным.

Возвраты:

неизменный набор характеристик коллектора