Hadoop 3.x（MapReduce）----【MapReduce 概述】---- 代码

package com.fickler.mapreduce.wordcount; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.IntWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Job; import org.apache.hadoop.mapreduce.lib.input.FileInputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; import java.io.IOException; /** * @author dell * @version 1.0 */ public class WordCountDriver { public static void main(String[] args) throws IOException, InterruptedException, ClassNotFoundException { //获取job Configuration configuration = new Configuration(); Job job = Job.getInstance(configuration); //设置jar包路径 job.setJarByClass(WordCountDriver.class); //关联mapper和reducer job.setMapperClass(WordCountMapper.class); job.setReducerClass(WordCountReducer.class); //设置map输出的key，value输出类型 job.setMapOutputKeyClass(Text.class); job.setMapOutputValueClass(IntWritable.class); //设置最终输出的key，value类型 job.setOutputKeyClass(Text.class); job.setMapOutputValueClass(IntWritable.class); //设置输入路径和输出路径 FileInputFormat.setInputPaths(job, new Path("C:\\Users\\dell\\Desktop\\input")); FileOutputFormat.setOutputPath(job, new Path("C:\\Users\\dell\\Desktop\\output")); //提交job boolean result = job.waitForCompletion(true); System.exit(result ? 0 : 1); } }