Simple Map/Reduce pipelines in Java