Поскольку существует предел для размера счетчика oop (и мы не хотим увеличивать его только для одного задания), я создаю карту (Карта), которая будет увеличивать ключ при выполнении некоторых условий (То же, что и счетчики). ). Уже существует DoFn (возвращающий пользовательский объект), который обрабатывает данные, поэтому мне интересно передать карту в нее и сгруппировать ее снаружи на основе ключей. Я думаю, что concurrenthashmap может работать, но не может реализовать то же самое.