完成maven工程的创建;完成mapper、reducer、FileOutputFormat编程

创建Maven项目并整合Hadoop MapReduce通常包括以下几个步骤：

1. **创建Maven项目**：
- 使用Eclipse、IntelliJ IDEA或其他支持Maven的IDE，选择"New Maven Project"或者右键选择"New -> Maven Project"。
- 配置基本信息，如groupId、artifactId和version，并选择合适的模板，例如"Maven Archetype Web Application"。

2. **添加MapReduce依赖**：
- 在pom.xml文件中添加Hadoop的依赖，比如`<dependency>`标签：

     <dependency>
         <groupId>org.apache.hadoop</groupId>
         <artifactId>hadoop-client</artifactId>
         <version>版本号</version>
     </dependency>

- 确保替换`版本号`为实际的Hadoop库版本。

3. **Mapper编程**：
- 创建Mapper类，实现`Mapper<LongWritable, Text, KeyWritable, Value>`接口。
- 实现`map()`方法处理输入数据，将键值对转换为新的键值对。

4. **Reducer编程**：
- 创建Reducer类，实现`Reducer<KeyWritable, Iterable<Value>, KeyWritable, Value>`接口。
- 实现`reduce()`方法接收Mapper输出的结果，对相似键的值进行汇总。

5. **FileOutputFormat编程**：
- 文件输出通常使用`org.apache.hadoop.mapreduce.lib.output.FileOutputFormat`，它会负责写入到指定的HDFS路径。
- 在Mapper或Reducer类中调用`context.write(key, value)`来输出结果。

6. **编写Driver类**：
- 创建Driver类，通过`Job`对象提交任务，并设置Mapper和Reducer类以及输出目录。

public static void main(String[] args) throws Exception {
    Configuration conf = new Configuration();
    Job job = Job.getInstance(conf, "YourJobName");
    // 设置Mapper和Reducer
    job.setMapperClass(MyMapper.class);
    job.setReducerClass(MyReducer.class);
    // 输出路径
    FileOutputFormat.setOutputPath(job, new Path("hdfs://namenode:port/output/path"));
    // 启动任务
    boolean success = job.waitForCompletion(true);
}