[FLINK-1053] Add "mapPartition" operator.
[FLINK-1053] Cleanup implementation of mapPartition function

This closes #42