Hadoop基本的Map/Reduce
HelloHadoop.class
?
Mapper
public static void main(String[] args) { Configuration conf = new Configuration(); Job job = new Job(conf, "Hadoop Hello World"); job.setJarByClass(HelloHadoop.class); FileInputFormat.setInputPaths(job, "input"); FileOutputFormat.setOutputPath(job, new Path("output")); job.setMapperClass(HelloMapper.class); job.setReducerClass(HelloReducer.class); job.waitForCompletion(true);}