There should be a Reducer<String,String,String,String> subclass, especially for use in Streaming so you don't have to shell out to a separate JVM.