protected void reduce(IntWritable key, Iterablevalues, Context context) throws IOException, InterruptedException { //因为在map到reduce之间它会将key(评论时间)升序排列,我们使用使Sort阶段的Key降序排列的比较器后, // 在reduce得到的key就是降序排列的,我们直接输出前十个数据就好了 if (i < 10) { for (Text value : values) { String date = timeStamp2Date(String.valueOf(key), "yyyy-MM-dd HH:mm:ss"); context.write(value, new Text(date)); } i++; } }



