package cn.jecn.hadoop.mapreduce.com;

import java.io.IOException;
import java.util.StringTokenizer;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

public class MapperClass extends Mapper<Object, Text, Text, IntWritable>{
	
	public Text keyText=new Text("key");
	public IntWritable intValue=new IntWritable(1);

	@Override
	protected void map(Object key, Text value,
			Context context)
			throws IOException, InterruptedException {
		
		//获取第一行的值
		String str=value.toString();
		
		StringTokenizer stringtokenizer=new StringTokenizer(str);
		
		while (stringtokenizer.hasMoreTokens()) {
			keyText.set(stringtokenizer.nextToken());
			context.write(keyText, intValue);
		}
	}
    
}