Aggregation Operations In Big Data Pipelines