public class IndustryMapper extends Mapper<LongWritable, Text, Text, IntWritable> { protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException { // 1 将maptask传给我们的文本内容先转换成String String line = value.toString(); // 2 根据,将这一行切分成多个字段 String[] fields = line.split(","); // 3 取其中的所属分类字段 String industry = fields[8]; // 4 将所属分类输出为<所属分类,1>,以便于后续的数据分发 context.write(new Text(industry), new IntWritable(1)); }}