Create only one result tuple in mapper and reducer
remove erroneous TODO comment
use parallelism of input operator for first mapper
better exception messages
split test cases into unit and aggregation tests
shorter name for aggregation mappers and reducer