aggregate  pipeline operators