Add aggregator To getFlow method