Aggregation pipeline