MapReduce字数统计案例

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（“loglevel::“+str[1]）;
		context.write（ss new IntWritable（1））;
		ss.clear（）;
		ss.set（“logresource::“+str[2]）;
		context.write（ss new IntWritable（1））;
	}
}