好吧，我承认用Hadoop来处理大数据是件很酷的事。但是有时候在做course project的时候还是让我很受挫。

如何用mapper处理多输入的情况：

多个mapper：每个mapper处理对应的输入文件

      MultipleInputs.addInputPath(conf, new Path(args[0]), TextInputFormat.class, CustomerMap.class);  MultipleInputs.addInputPath(conf, new Path(args[1]), TextInputFormat.class, TransactionMap.class);  FileOutputFormat.setOutputPath(conf, new Path(args[2]));

一个mapper：一个mapper处理所有不同的文件：（如下代码段，在mapper内部，我们可以数据来自哪个文件，然后进行相应的处理）

          public static class Map extends MapReduceBase implements Mapper
    
          {	public void map(LongWritable key, Text value, OutputCollector
     
       output, Reporter reporter) throws IOException 	{		//Get FileName from reporter		FileSplit fileSplit = (FileSplit)reporter.getInputSplit();		String filename = fileSplit.getPath().getName();		//String line = value.toString();		output.collect(new Text(filename),value);  			    }    }
     
    

PS: mapper的输入可以是一个文件夹：FileInputFormat.setInputPaths(conf, new Path("/tmp/"));