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

This closes #42
Small bug fixes for running hadoop output formats

This closes #75