我已经实现了一个简单的map reduce应用程序来检测最长的单词。作业成功执行。
但现在我想知道在减速机中使用局部变量来保持最大长度是否正确？因为在一个分布式环境中可能有多个缩减器，并且它们不共享该变量的值。
这是一个正确的假设吗？
在分布式环境中，当有独立的减速机时，输出将受到怎样的影响？
我使用一个定制的比较器，所以单词首先按长度排序，然后按值排序。每个mr阶段的输出如下所示：

Mapper Output:
ByeByeBye   9
HelloHelloHe222 15
HelloHelloHe222 15
HelloHelloHe333 15
HelloHelloHe333 15
HelloHelloHellw99999 20

Combiner Output:
ByeByeBye   9
HelloHelloHe222 15
HelloHelloHe333 15
HelloHelloHellw99999    20

ComparatorOutput:
HelloHelloHellw99999    20
HelloHelloHe222 15
HelloHelloHe333 15
ByeByeBye   9

Reducer Output:
HelloHelloHellw99999    20

减速器等级：

public class WordsReducer extends Reducer<Text, IntWritable, Text, IntWritable> {
    private int maxLength = Integer.MIN_VALUE;
    private IntWritable length = new IntWritable();

    @Override
    protected void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException {
        length = values.iterator().next();
        if (length.get() >= maxLength){
            maxLength = length.get();
            context.write(key, length);
        }
    }
}