added realtime aggregation to the system