Added aggregator in query stream.