草庐IT

MultipleInput

全部标签

java - 如何在 mapreduce 中使用 MultipleInput 类?

我有一个问题。我需要两个文件作为mapreduce程序的输入。@Overridepublicintrun(String[]args)throwsException{(argumentskip)Jobjob1=newJob();job1.setJarByClass(CFRecommenderDriver.class);job1.setMapperClass(CFRecommenderMapper.class);//job1.setReducerClass(CFRecommenderReducer.class);job1.setMapOutputKeyClass(Text.class);j