Должны ли сумматор и вычитатель в Kafka Streams KGroupedTable.aggregate возвращать новый неизменяемый агрегатор при кажд ⇐ JAVA

[Anonymous]

Я хочу объединить записи KTable в карту наборов (например, Map), поэтому в функции агрегирования мне нужно указать сумматор и вычитатель, которые выглядят так:

Код: Выделить всё

(key, value, map) -> {
map.computeIfAbsent(key, k -> new HashSet()).add(value);
return map;
},
(key, value, map) -> {
map.computeIfAbsent(key, k -> new HashSet()).remove(value)
return map;
}

Мой вопрос: можно ли вернуть карту как есть, или агрегатор должен быть неизменяемым объектом, который заставит меня глубоко клонировать всю карту наборов при каждом вызове?< /п>

Подробнее здесь: https://stackoverflow.com/questions/789 ... tor-return