Note that the changes to TypedPipe.aggregate and Grouped.aggregate can be reverted once the corresponding patch to algebird (making Aggregator type variant) propagates.