hadoop - 无法访问reduce类中的reduce方法

Question

 public static class Reduce extends Reducer<Text, Text, Text, Text>
    {
        private Text txtReduceOutputKey = new Text("");
        private Text txtReduceOutputValue = new Text("");
    public void reduce(Text key, Iterator<Text> values, Context context) throws IOException, InterruptedException
    {
        //some code;
    }
}

它没有给出任何错误。我可以访问这些类，因为我可以启动这些变量 txtReduceOutputKey和 txtReduceOutputValue。但是 reduce方法在执行时会被忽略。因此，我无法运行上述方法中的代码//某些代码。我也正在使用以下软件包。

import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.Job;

知道如何解决这个问题吗？

Answer 1

请确保已在驱动程序代码中设置了 Reducer类。
例如 :-

job.setReducerClass(Base_Reducer.class);