MapReduce的Wordcount求top
//自定义MyMapper类继承Mapper public class MyMapper extends Mapper { private Text outkey = new Text(); private IntWritable outval = new IntWritable(1); private String [] strs = null; //实现map方法 @Override protected void map(LongWritable key, Text value, Mapper.Context context) throws IOException, Interrupt
下载地址
用户评论