moved aggregator from beam to here