package?mytest;

import?java.io.IOException;

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

public?class?myMapper?extends?Mapper?{
	
	@Override
	protected?void?map（LongWritable?key?Text?value?Mapper.Context?context）
			throws?IOException?InterruptedException?{
		String[]?str?=?value.toString（）.split（“?“）;
//		for（String?ss:str）?{
//			context.write（new?Text（ss）?new?IntWritable（1））;
//		}
		Text?ss?=?new?Text（）;
		ss.set（“l(fā)oglevel::“+str[1]）;
		context.write（ss?new?IntWritable（1））;
		ss.clear（）;
		ss.set（“l(fā)ogresource::“+str[2]）;
		context.write（ss?new?IntWritable（1））;
	}
}