This is a feature gap between aggregation and mapReduce which we intend to close, but probably has some dependencies on PM-1051. This work is to identify those dependencies and write down why they would help achieve this. Also to make sure we don't have a dependency cycle between this project and PM-1051.