读书人

Hadoop根本的Map/Reduce

发布时间: 2012-10-15 09:45:25 作者: rapoo

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);}

读书人网 >编程

热点推荐