Referring to our example, the aggregation information needs to contain the weighted sum of all values passed in so far (for that group) and the count for the number of values already processed.