你不能这样做，如果你的输入文件有3个分裂，那么你将有3个Map器运行。每个Map器都有其各自的计数值（取决于如何增加计数值的逻辑），并且只有在所有Map器在shuffle阶段完成后，reduce端才会知道。
如果要限制Map输出。然后有一个减速机 job.setNumReduceTasks(1) 限制减速机的输出。像这样的。

public static class WLReducer2 extends
        Reducer<IntWritable, Text, Text, IntWritable> {
    int count=0;
    @Override
    protected void reduce(IntWritable key, Iterable<Text> values,
            Context context) throws IOException, InterruptedException {

        for (Text x : values) {
            if (count < 5)
            context.write(key, x);
            count++;
        }

    };
}

如果你想得到reduce端的计数器值。您可以将其添加到reduce设置方法中。

@Override
    public void setup(Context context) throws IOException, InterruptedException{
        Configuration conf = context.getConfiguration();
        Cluster cluster = new Cluster(conf);
        Job currentJob = cluster.getJob(context.getJobID());
        mapperCounter = currentJob.getCounters().findCounter(COUNTER_NAME).getValue();  
    }