adding support for aggregation pipleline