Агрегатные функции требуют обработки всего набора данных для расчета. Модель обработки, ориентированная на фрагменты, не очень удобна для реализации такого рода функций, поскольку данные обрабатываются отдельными частями.
В вашем случае, поскольку данные считываются из базы данных, я бы оставил группировку / суммирование в база данных с чем-то вроде select sum(fieldB) ... group by fieldB
. Базы данных хорошо оптимизированы для такого рода задач, и вам следует прочитать одну запись для каждой группы.