text: public HadoopJarStepConfig toHadoopJarStepConfig() {List<String> args = new ArrayList<String>();if (reducer == null) {hadoopConfig.put("mapred.reduce.tasks", "0");}for (Map.Entry<String, String> entry : hadoopConfig.entrySet()) {args.add("-D");args.add(entry.getKey() + "=" + entry.getValue());}for (String input : inputs) {args.add("-input");args.add(input);}if (output != null) {args.add("-output");args.add(output);}if (mapper != null) {args.add("-mapper");args.add(mapper);}if (reducer != null) {args.add("-reducer");args.add(reducer);}return new HadoopJarStepConfig().withJar("/home/hadoop/contrib/streaming/hadoop-streaming.jar").withArgs(args);}