Not particularly great this one... A Stratosphere ```Collector``` is wrapped everytime ```reduce``` is called which is not elegant. As I am aware, the implementation of ```Collector``` interface is not configurable in Stratosphere via the user and one should work to the job driver level (the caller of the ```reduce``` function to utilise this one. I can do that, but what do you think would be the best approach?