GroupByKey/CombinePerKey – aggregation across elements